Skip to content

Commit d2feeab

Browse files
committed
[feat-34672][kudu] 修复batchSize不能传入
1 parent 298fbd3 commit d2feeab

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kudu/kudu-sink/src/main/java/com/dtstack/flink/sql/sink/kudu/table/KuduSinkParser.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,8 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S
5151
kuduTableInfo.setWorkerCount(MathUtil.getIntegerVal(props.get(WORKER_COUNT.toLowerCase())));
5252
kuduTableInfo.setDefaultOperationTimeoutMs(MathUtil.getIntegerVal(props.get(OPERATION_TIMEOUT_MS.toLowerCase())));
5353
kuduTableInfo.setDefaultSocketReadTimeoutMs(MathUtil.getIntegerVal(props.get(SOCKET_READ_TIMEOUT_MS.toLowerCase())));
54-
kuduTableInfo.setBatchSize(MathUtil.getIntegerVal(props.getOrDefault(BATCH_SIZE_KEY, DEFAULT_BATCH_SIZE)));
55-
kuduTableInfo.setBatchWaitInterval(MathUtil.getIntegerVal(props.getOrDefault(BATCH_WAIT_INTERVAL_KEY, DEFAULT_BATCH_WAIT_INTERVAL)));
54+
kuduTableInfo.setBatchSize(MathUtil.getIntegerVal(props.getOrDefault(BATCH_SIZE_KEY.toLowerCase(), DEFAULT_BATCH_SIZE)));
55+
kuduTableInfo.setBatchWaitInterval(MathUtil.getIntegerVal(props.getOrDefault(BATCH_WAIT_INTERVAL_KEY.toLowerCase(), DEFAULT_BATCH_WAIT_INTERVAL)));
5656

5757
if (Objects.isNull(props.get(SESSION_FLUSH_MODE_KEY))) {
5858
if (kuduTableInfo.getBatchSize() > 1) {

0 commit comments

Comments
 (0)