You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/11/26 01:17:33 UTC
[iotdb] branch master updated: print status code name when dispatch failed (#8150)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 2a1e33a176 print status code name when dispatch failed (#8150)
2a1e33a176 is described below
commit 2a1e33a176bc2a14b6c208d21d651b486e65451d
Author: Zhang.Jinrui <xi...@gmail.com>
AuthorDate: Sat Nov 26 09:17:28 2022 +0800
print status code name when dispatch failed (#8150)
---
.../iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
index e8437f5e4b..c3635d51cf 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
@@ -171,8 +171,9 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
TSendPlanNodeResp sendPlanNodeResp = client.sendPlanNode(sendPlanNodeReq);
if (!sendPlanNodeResp.accepted) {
logger.error(
- "dispatch write failed. status: {}, message: {}, node {}",
+ "dispatch write failed. status: {}, code: {}, message: {}, node {}",
sendPlanNodeResp.status,
+ TSStatusCode.representOf(sendPlanNodeResp.status.code),
sendPlanNodeResp.message,
endPoint);
if (sendPlanNodeResp.getStatus() == null) {