(iotdb) branch connection-retry updated: Update IoTDBDataRegionAsyncSink.java

[justinchen]

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

justinchen pushed a commit to branch connection-retry
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/connection-retry by this push:
     new 1b2d04f432b Update IoTDBDataRegionAsyncSink.java
1b2d04f432b is described below

commit 1b2d04f432bfee6a04529aec8974ebfb7ce05d83
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Feb 6 10:26:22 2026 +0800

    Update IoTDBDataRegionAsyncSink.java
---
 .../db/pipe/sink/protocol/thrift/async/IoTDBDataRegionAsyncSink.java     | 1 +
 1 file changed, 1 insertion(+)

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 95e36ee923f..7b7ce628f82 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
@@ -127,6 +127,7 @@ public class IoTDBDataRegionAsyncSink extends IoTDBSink {
       new ConcurrentHashMap<>();
 
   private boolean enableSendTsFileLimit;
+  private volatile boolean isConnectionException;
 
   @Override
   public void validate(final PipeParameterValidator validator) throws 
Exception {