From da5bf483c9c6ace3a5742f2dc8a10f9545b2c518 Mon Sep 17 00:00:00 2001 From: kino 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 | 5 +---- 1 file changed, 1 insertion(+), 4 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..f087689cf4 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; @@ -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); }