We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 19af9ae + ad7c84a commit 10db7cfCopy full SHA for 10db7cf
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