Merge branch 'hotfix_1.8_batchSizeOOM_22787' into 'test_3.10.x_oom'

设置batchSize上限



See merge request !255

Author: zoudaokoulife

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

@@ -29,6 +29,8 @@
  */
 public class RdbTableInfo extends TargetTableInfo {
 
+    public static final int MAX_BATCH_SIZE = 10000;
+
     public static final String URL_KEY = "url";
 
     public static final String TABLE_NAME_KEY = "tableName";
@@ -144,6 +146,10 @@ public boolean check() {
         Preconditions.checkNotNull(tableName, "rdb field of tableName is required");
         Preconditions.checkNotNull(userName, "rdb field of userName is required");
         Preconditions.checkNotNull(password, "rdb field of password is required");
+
+        if (null != batchSize) {
+            Preconditions.checkArgument(batchSize <= MAX_BATCH_SIZE, "batchSize must be less than " + MAX_BATCH_SIZE);
+        }
         return true;
     }