Skip to content

Commit 03f46f1

Browse files
committed
add default batch wait interval
1 parent b880437 commit 03f46f1

File tree

1 file changed

+1
-1
lines changed
  • rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb

1 file changed

+1
-1
lines changed

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/RdbSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ public abstract class RdbSink implements RetractStreamTableSink<Row>, Serializab
6363

6464
protected int batchNum = 1;
6565

66-
protected long batchWaitInterval;
66+
protected long batchWaitInterval = 10000;
6767

6868
protected int[] sqlTypes;
6969

0 commit comments

Comments
 (0)