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/11 13:57:28 UTC

[iotdb] branch xingtanzjr/0511_test updated: spotless

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 <xi...@gmail.com>
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(),