Skip to content

Commit 9eb588b

Browse files
committed
rdb batch num 100
1 parent 204cc39 commit 9eb588b

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
@@ -61,7 +61,7 @@ public abstract class RdbSink implements RetractStreamTableSink<Row>, Serializab
6161

6262
protected String dbType;
6363

64-
protected int batchNum = 1;
64+
protected int batchNum = 100;
6565

6666
protected long batchWaitInterval = 10000;
6767

0 commit comments

Comments
 (0)