Skip to content

Commit

Permalink
[hotfix-1908][chunjun-connector-starrocks]: starrocks data size check
Browse files Browse the repository at this point in the history
  • Loading branch information
kinoxyz1 authored and yanghuaiGit committed Jul 30, 2024
1 parent e624fb4 commit e24b617
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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", 1024);
starRocksConfig.setBatchSize(batchSize);
super.initCommonConf(starRocksConfig);
}
Expand Down

0 comments on commit e24b617

Please sign in to comment.