rdb batch num 100
@@ -61,7 +61,7 @@ public abstract class RdbSink implements RetractStreamTableSink<Row>, Serializab
protected String dbType;
- protected int batchNum = 1;
+ protected int batchNum = 100;
protected long batchWaitInterval = 10000;
