This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-batch in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 42e7adc49593246add8e94a01524fce016d8e279 Author: Steve Yurong Su <[email protected]> AuthorDate: Thu Apr 24 12:36:22 2025 +0800 Update PipeTransferBatchReqBuilder.java --- .../payload/evolvable/batch/PipeTransferBatchReqBuilder.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTransferBatchReqBuilder.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTransferBatchReqBuilder.java index 7d8162b0df2..179ed0fee55 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTransferBatchReqBuilder.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTransferBatchReqBuilder.java @@ -112,7 +112,9 @@ public class PipeTransferBatchReqBuilder implements AutoCloseable { ? CONNECTOR_IOTDB_TS_FILE_BATCH_SIZE_DEFAULT_VALUE : CONNECTOR_IOTDB_PLAIN_BATCH_SIZE_DEFAULT_VALUE); this.defaultBatch = - new PipeTabletEventTsFileBatch(requestMaxDelayInMs, requestMaxBatchSizeInBytes); + usingTsFileBatch + ? new PipeTabletEventTsFileBatch(requestMaxDelayInMs, requestMaxBatchSizeInBytes) + : new PipeTabletEventPlainBatch(requestMaxDelayInMs, requestMaxBatchSizeInBytes); } /**
