Merge branch '1.8_test_3.10.x_oom' into 1.8_test_3.10.x

Author: gituser

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

@@ -31,6 +31,8 @@
  */
 public class RdbTableInfo extends AbstractTargetTableInfo {
 
+    public static final int MAX_BATCH_SIZE = 10000;
+
     public static final String URL_KEY = "url";
 
     public static final String TABLE_NAME_KEY = "tableName";
@@ -170,6 +172,10 @@ public boolean check() {
         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);
+        }
+
         if (StringUtils.equalsIgnoreCase(updateMode, EUpdateMode.UPSERT.name())) {
             Preconditions.checkArgument(null != getPrimaryKeys() && getPrimaryKeys().size() > 0, "updateMode  mode primary is required");
         }