This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new 5d4277a49a1 Pipe: Removed the useless ban on async file transfer for
non realtime-first pipes (#17785)
5d4277a49a1 is described below
commit 5d4277a49a1c17af753dc767604c6791bab393e3
Author: Caideyipi <[email protected]>
AuthorDate: Thu May 28 18:43:02 2026 +0800
Pipe: Removed the useless ban on async file transfer for non realtime-first
pipes (#17785)
---
.../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 69dcb922e4a..aaef2ae435f 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
@@ -431,7 +431,7 @@ public class IoTDBDataRegionAsyncSink extends IoTDBSink {
},
transferTsFileClientManager.getExecutor());
- if (PipeConfig.getInstance().isTransferTsFileSync() || !isRealtimeFirst) {
+ if (PipeConfig.getInstance().isTransferTsFileSync()) {
try {
completableFuture.get();
} catch (final Exception e) {