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),

Reply via email to