[iotdb] branch BrokenPipe updated: add more message

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch BrokenPipe
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/BrokenPipe by this push:
     new 679c5b5793 add more message
679c5b5793 is described below

commit 679c5b5793a109a58afb45360ed113d4511e861f
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Wed May 11 21:27:48 2022 +0800

    add more message
---
 .../sync/SyncThriftClientWithErrorHandler.java      | 21 ++++++++++++++++++---
 1 file changed, 18 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 09a2a00946..f710300c85 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
@@ -54,9 +54,24 @@ public class SyncThriftClientWithErrorHandler implements 
MethodInterceptor {
       return methodProxy.invokeSuper(o, objects);
     } catch (InvocationTargetException e) {
       if (e.getTargetException() instanceof TException) {
+        Throwable t = e.getTargetException();
+        int level = 0;
+        while (t != null) {
+          LOGGER.error(
+              "level-{} Exception class {}, message {}",
+              level,
+              t.getClass().getName(),
+              t.getMessage());
+          t = t.getCause();
+        }
         Throwable rootCause = ExceptionUtils.getRootCause(e);
         // 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.
+        LOGGER.error(
+            "root cause message {}, LocalizedMessage {}, ",
+            rootCause.getMessage(),
+            rootCause.getLocalizedMessage(),
+            rootCause);
         if (rootCause instanceof SocketException
             && rootCause.getMessage().contains("Broken pipe")) {
           LOGGER.error(
@@ -67,13 +82,13 @@ public class SyncThriftClientWithErrorHandler implements 
MethodInterceptor {
           ((SyncThriftClient) o).invalidateAll();
         } else {
           LOGGER.error(
-              "Error in calling method {}, err: {}", method.getName(), 
e.getTargetException());
+              "Error in calling method1 {}, err: {}", method.getName(), 
e.getTargetException());
           ((SyncThriftClient) o).invalidate();
         }
       }
-      throw new TException("Error in calling method " + method.getName(), 
e.getTargetException());
+      throw new TException("Error in calling method2 " + method.getName(), 
e.getTargetException());
     } catch (Exception e) {
-      throw new TException("Error in calling method " + method.getName(), e);
+      throw new TException("Error in calling method3 " + method.getName(), e);
     }
   }
 }