(iotdb) branch dev/1.3 updated: Pipe: Fix unhandled timeout exceptions in Thrift Client (#16727) (#16731)

[jiangtian]

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

jiangtian 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 6dca30348ef Pipe: Fix unhandled timeout exceptions in Thrift Client 
(#16727) (#16731)
6dca30348ef is described below

commit 6dca30348ef8420ab455ca93b162bd7962ebe6e2
Author: Zhenyu Luo <zhe...@apache.org>
AuthorDate: Tue Nov 11 14:31:58 2025 +0800

    Pipe: Fix unhandled timeout exceptions in Thrift Client (#16727) (#16731)
    
    * Pipe: Fix unhandled timeout exceptions in Thrift Client
    
    * update
    
    (cherry picked from commit 93c55577e6f051307fa97656b17150aa038cb5de)
---
 .../src/main/java/org/apache/iotdb/commons/client/ThriftClient.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
index d2128bedaa4..76b7ac8c9f2 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
@@ -115,7 +115,8 @@ public interface ThriftClient {
             && (hasExpectedMessage(cause, "Connection reset by peer")
                 || hasExpectedMessage(cause, "Broken pipe")))
         || (cause instanceof ConnectException && hasExpectedMessage(cause, 
"Connection refused")
-            || (cause instanceof ClosedChannelException));
+            || (cause instanceof ClosedChannelException))
+        || (cause instanceof java.util.concurrent.TimeoutException);
   }
 
   static boolean hasExpectedMessage(Throwable cause, String expectedMessage) {