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 e75fc7bb5f308e04690a69ec4accf4bcca833b3d Author: Jinrui.Zhang <[email protected]> AuthorDate: Wed May 11 16:05:35 2022 +0800 add send fragmentinstance log --- .../apache/iotdb/db/mpp/plan/scheduler/SimpleFragInstanceDispatcher.java | 1 + 1 file changed, 1 insertion(+) 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 969ff3cca1..c91f0bc313 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 @@ -69,6 +69,7 @@ public class SimpleFragInstanceDispatcher implements IFragInstanceDispatcher { TSendFragmentInstanceReq req = new TSendFragmentInstanceReq( new TFragmentInstance(buffer), groupId, instance.getType().toString()); + LOGGER.info("send FragmentInstance[{}] to {}", instance.getId(), endPoint); resp = client.sendFragmentInstance(req); } catch (IOException e) { LOGGER.error("can't connect to node {}", endPoint, e);
