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:07:31 UTC
[iotdb] 02/03: add log and error handle when send fragment instance
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 <xi...@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());