[hotfix-1908][chunjun-connector-starrocks]: starrocks data size check

DTStack · Jul 30, 2024 · da5bf48 · da5bf48
1 parent e624fb4
commit da5bf48
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/...ocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java b/...ocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java
@@ -36,8 +36,6 @@
 
 import java.util.stream.Collectors;
 
-import static com.dtstack.chunjun.connector.starrocks.options.ConstantValue.SINK_BATCH_MAX_ROWS_DEFAULT;
-
 public class StarRocksSinkFactory extends SinkFactory {
 
     private final StarRocksConfig starRocksConfig;
@@ -49,8 +47,7 @@ public StarRocksSinkFactory(SyncConfig syncConfig) {
                         JsonUtil.toJson(syncConfig.getWriter().getParameter()),
                         StarRocksConfig.class);
 
-        int batchSize =
-                (int) syncConfig.getWriter().getLongVal("batchSize", SINK_BATCH_MAX_ROWS_DEFAULT);
+        int batchSize = (int) syncConfig.getWriter().getLongVal("batchSize", 100000);
         starRocksConfig.setBatchSize(batchSize);
         super.initCommonConf(starRocksConfig);
     }