Skip to content

Commit 31093ce

Browse files
committed
[hotfix-1908][chunjun-connector-starrocks]: starrocks data size check
1 parent e624fb4 commit 31093ce

File tree

1 file changed

+1
-4
lines changed
  • chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink

1 file changed

+1
-4
lines changed

chunjun-connectors/chunjun-connector-starrocks/src/main/java/com/dtstack/chunjun/connector/starrocks/sink/StarRocksSinkFactory.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,6 @@
3636

3737
import java.util.stream.Collectors;
3838

39-
import static com.dtstack.chunjun.connector.starrocks.options.ConstantValue.SINK_BATCH_MAX_ROWS_DEFAULT;
40-
4139
public class StarRocksSinkFactory extends SinkFactory {
4240

4341
private final StarRocksConfig starRocksConfig;
@@ -49,8 +47,7 @@ public StarRocksSinkFactory(SyncConfig syncConfig) {
4947
JsonUtil.toJson(syncConfig.getWriter().getParameter()),
5048
StarRocksConfig.class);
5149

52-
int batchSize =
53-
(int) syncConfig.getWriter().getLongVal("batchSize", SINK_BATCH_MAX_ROWS_DEFAULT);
50+
int batchSize = (int) syncConfig.getWriter().getLongVal("batchSize", 1024);
5451
starRocksConfig.setBatchSize(batchSize);
5552
super.initCommonConf(starRocksConfig);
5653
}

0 commit comments

Comments
 (0)