We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7c2555f commit ad7c84aCopy full SHA for ad7c84a
1 file changed
core/src/main/java/com/dtstack/flink/sql/table/AbstractTableInfo.java
@@ -68,7 +68,8 @@ public abstract class AbstractTableInfo implements Serializable {
68
* error data limit. Task will failed once {@link AbstractDtRichOutputFormat#outDirtyRecords}
69
* count over limit. Default 1000L;
70
*/
71
- private Long errorLimit = 0L;
+ // TODO: 暂时默认值设置为10000,后面排期支持在产品上设置
72
+ private Long errorLimit = 10000L;
73
74
public String[] getFieldTypes() {
75
return fieldTypes;
0 commit comments