You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/05/19 10:29:46 UTC

(iotdb) branch Remove-uselss created (now cd0d72e3115)

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

Caideyipi pushed a change to branch Remove-uselss
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at cd0d72e3115 Update IoTDBDataRegionAsyncSink.java

This branch includes the following new commits:

     new cd0d72e3115 Update IoTDBDataRegionAsyncSink.java

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

(iotdb) 01/01: Update IoTDBDataRegionAsyncSink.java

Posted by ju...@apache.org.
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 <87...@users.noreply.github.com>
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) {