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
The following commit(s) were added to refs/heads/fix-pipe-batch by this push:
new fea11e3f1e1 Update PipeTransferBatchReqBuilder.java
fea11e3f1e1 is described below
commit fea11e3f1e12a5e49fd8a57321541bc78219343b
Author: Steve Yurong Su <[email protected]>
AuthorDate: Thu Apr 24 13:04:14 2025 +0800
Update PipeTransferBatchReqBuilder.java
---
.../connector/payload/evolvable/batch/PipeTransferBatchReqBuilder.java | 1 -
1 file changed, 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 179ed0fee55..50160ba61f6 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
@@ -104,7 +104,6 @@ public class PipeTransferBatchReqBuilder implements
AutoCloseable {
requestMaxDelayInMs =
requestMaxDelayInMillis < 0 ? Integer.MAX_VALUE :
requestMaxDelayInMillis;
}
-
requestMaxBatchSizeInBytes =
parameters.getLongOrDefault(
Arrays.asList(CONNECTOR_IOTDB_BATCH_SIZE_KEY,
SINK_IOTDB_BATCH_SIZE_KEY),