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(),