You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/05/12 03:08:38 UTC
[iotdb] branch xingtanzjr/0511_test updated: optimize
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/0511_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xingtanzjr/0511_test by this push:
new c23dbd2843 optimize
c23dbd2843 is described below
commit c23dbd28437fc26834d514ce98ede35cc2ef0445
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Thu May 12 11:08:28 2022 +0800
optimize
---
.../iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java
index ad586d33bf..0601ebe251 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java
@@ -97,7 +97,7 @@ public class SyncThriftClientWithErrorHandler implements MethodInterceptor {
private boolean isConnectionBroken(Throwable cause) {
return (cause instanceof SocketException && cause.getMessage().contains("Broken pipe"))
- || cause instanceof TTransportException
- && cause.getMessage().contains("Socket is closed by peer");
+ || (cause instanceof TTransportException
+ && cause.getMessage().contains("Socket is closed by peer"));
}
}