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
commit 96d0b95419096ffd5aad7a601c5f11c07da31383 Author: Jinrui.Zhang <[email protected]> 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());
