This is an automated email from the ASF dual-hosted git repository. Caideyipi pushed a commit to branch Remove-uselss in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cd0d72e3115e8b9e96a7d8f841826eaf8c431f31 Author: Caideyipi <[email protected]> AuthorDate: Tue May 19 18:29:32 2026 +0800 Update IoTDBDataRegionAsyncSink.java --- .../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 9adbcf6cf16..f921d9077b1 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 @@ -457,7 +457,7 @@ public class IoTDBDataRegionAsyncSink extends IoTDBSink { }, transferTsFileClientManager.getExecutor()); - if (PipeConfig.getInstance().isTransferTsFileSync() || !isRealtimeFirst) { + if (PipeConfig.getInstance().isTransferTsFileSync()) { try { completableFuture.get(); } catch (final Exception e) {
