[iotdb] branch xingtanzjr/0511_test updated: add log and error handle when send fragment instance

[xingtanzjr]

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 43aad05646 add log and error handle when send fragment instance
43aad05646 is described below

commit 43aad05646ff2ac8b9785065f40d3c2e50c24be8
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Wed May 11 16:42:23 2022 +0800

    add log and error handle when send fragment instance
---
 .../iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java      | 3 ++-
 .../org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java   | 1 +
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
index c91f0bc313..ba53e4fe2d 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java
@@ -28,6 +28,7 @@ import org.apache.iotdb.mpp.rpc.thrift.TFragmentInstance;
 import org.apache.iotdb.mpp.rpc.thrift.TSendFragmentInstanceReq;
 import org.apache.iotdb.mpp.rpc.thrift.TSendFragmentInstanceResp;
 
+import org.apache.thrift.TException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -71,7 +72,7 @@ public class SimpleFragInstanceDispatcher implements 
IFragInstanceDispatcher {
                       new TFragmentInstance(buffer), groupId, 
instance.getType().toString());
               LOGGER.info("send FragmentInstance[{}] to {}", instance.getId(), 
endPoint);
               resp = client.sendFragmentInstance(req);
-            } catch (IOException e) {
+            } catch (IOException | TException e) {
               LOGGER.error("can't connect to node {}", endPoint, e);
               throw e;
             }
diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
index e2a1fff0c3..54b9f82278 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
@@ -87,6 +87,7 @@ public class InternalServiceImpl implements 
InternalService.Iface {
 
   @Override
   public TSendFragmentInstanceResp 
sendFragmentInstance(TSendFragmentInstanceReq req) {
+    LOGGER.info("receive FragmentInstance to group[{}]", 
req.getConsensusGroupId());
     QueryType type = QueryType.valueOf(req.queryType);
     ConsensusGroupId groupId =
         
ConsensusGroupId.Factory.createFromTConsensusGroupId(req.getConsensusGroupId());