From 305d1f9d1c6a461105fe6346d4ed6899d19f0ac6 Mon Sep 17 00:00:00 2001
From: kino <kinoxyz1@gmail.com>
Date: Tue, 30 Jul 2024 15:57:58 +0800
Subject: [PATCH] [hotfix-1908][chunjun-connector-starrocks]: starrocks data
 size check

---
 .../connector/starrocks/sink/StarRocksSinkFactory.java        | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java b/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java
index 1dafbbe490..daed05b9f3 100644
--- a/chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java
+++ b/chunjun-connectors/chunjun-connector-starrocks/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;
@@ -50,7 +48,7 @@ public StarRocksSinkFactory(SyncConfig syncConfig) {
                         StarRocksConfig.class);
 
         int batchSize =
-                (int) syncConfig.getWriter().getLongVal("batchSize", SINK_BATCH_MAX_ROWS_DEFAULT);
+                (int) syncConfig.getWriter().getLongVal("batchSize", 100000);
         starRocksConfig.setBatchSize(batchSize);
         super.initCommonConf(starRocksConfig);
     }