This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch IOTDB-6200 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 024e0542ea23718ff13c31a3b61517e334e75e6d Author: JackieTien97 <[email protected]> AuthorDate: Tue Oct 24 12:06:24 2023 +0800 add more exceptions --- .../src/main/java/org/apache/iotdb/commons/client/ThriftClient.java | 5 ++++- 1 file changed, 4 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 7b3924a90d3..92d933397e6 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 @@ -27,6 +27,7 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.lang.reflect.InvocationTargetException; +import java.net.ConnectException; import java.net.SocketException; /** @@ -109,6 +110,8 @@ public interface ThriftClient { && (cause.getMessage().contains("Socket is closed by peer") || cause.getMessage().contains("Read call frame size failed"))) || (cause instanceof IOException - && cause.getMessage().contains("Connection reset by peer")); + && (cause.getMessage().contains("Connection reset by peer") + || cause.getMessage().contains("Broken pipe"))) + || (cause instanceof ConnectException && cause.getMessage().contains("Connection refused")); } }
