(iotdb) branch master updated: Pipe: Fix unhandled timeout exceptions in Thrift Client (#16727)

[justinchen]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 93c55577e6f Pipe: Fix unhandled timeout exceptions in Thrift Client 
(#16727)
93c55577e6f is described below

commit 93c55577e6f051307fa97656b17150aa038cb5de
Author: Zhenyu Luo <zhe...@apache.org>
AuthorDate: Tue Nov 11 10:50:20 2025 +0800

    Pipe: Fix unhandled timeout exceptions in Thrift Client (#16727)
    
    * Pipe: Fix unhandled timeout exceptions in Thrift Client
    
    * update
---
 .../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 6c1b9d3fb0a..0b78e51a99a 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) {