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 4337d8a7d4 spotless
4337d8a7d4 is described below

commit 4337d8a7d435e79e389fcf79cdf4c7953ba2fb6e
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Wed May 11 21:57:18 2022 +0800

    spotless
---
 .../iotdb/commons/client/sync/SyncThriftClientWithErrorHandler.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 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 651b5a8466..c726e0bf03 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
@@ -70,7 +70,7 @@ public class SyncThriftClientWithErrorHandler implements 
MethodInterceptor {
         }
         ((SyncThriftClient) o).invalidate();
       }
-      
+
       Throwable rootCause = ExceptionUtils.getRootCause(t);
       // if the exception is SocketException and its error message is Broken 
pipe, it means that
       // the remote node may restart and all the connection we cached before 
should be cleared.
@@ -79,8 +79,7 @@ public class SyncThriftClientWithErrorHandler implements 
MethodInterceptor {
           rootCause.getMessage(),
           rootCause.getLocalizedMessage(),
           rootCause);
-      if (rootCause instanceof SocketException
-          && rootCause.getMessage().contains("Broken pipe")) {
+      if (rootCause instanceof SocketException && 
rootCause.getMessage().contains("Broken pipe")) {
         LOGGER.error(
             "Broken pipe error happened in calling method {}, we need to clear 
all previous cached connection, err: {}",
             method.getName(),

Reply via email to