(iotdb) branch master updated: Pipe: Removed the useless ban on async file transfer for non realtime-first pipes

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

Caideyipi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 329fa102a49 Pipe: Removed the useless ban on async file transfer for 
non realtime-first pipes
329fa102a49 is described below

commit 329fa102a49e5350ca213c6f69be2408170d34e6
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu May 28 16:57:17 2026 +0800

    Pipe: Removed the useless ban on async file transfer for non realtime-first 
pipes
---
 .../db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
index 32a2c191048..c607490b362 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java
@@ -455,7 +455,7 @@ public class IoTDBDataRegionAsyncSink extends IoTDBSink {
             },
             transferTsFileClientManager.getExecutor());
 
-    if (PipeConfig.getInstance().isTransferTsFileSync() || !isRealtimeFirst) {
+    if (PipeConfig.getInstance().isTransferTsFileSync()) {
       try {
         completableFuture.get();
       } catch (final Exception e) {