This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch force_ci/object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d24cddadbd2f80fb4b1e7896515e5ddc508aeb95 Author: Zhenyu Luo <[email protected]> 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 (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 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) {
