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/10/08 11:36:29 UTC
[iotdb] branch master updated: print status when write failed both in remote and local (#7544)
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 1e4d28f29d print status when write failed both in remote and local (#7544)
1e4d28f29d is described below
commit 1e4d28f29de9e38c67da61b39a609c4d0f77e03c
Author: Zhang.Jinrui <xi...@gmail.com>
AuthorDate: Sat Oct 8 19:36:24 2022 +0800
print status when write failed both in remote and local (#7544)
---
.../db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
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 9f736ca222..1128b97341 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
@@ -170,7 +170,10 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
instance.getRegionReplicaSet().getRegionId());
TSendPlanNodeResp sendPlanNodeResp = client.sendPlanNode(sendPlanNodeReq);
if (!sendPlanNodeResp.accepted) {
- logger.error(sendPlanNodeResp.message);
+ logger.error(
+ "dispatch write failed. status: {}, message: {}",
+ sendPlanNodeResp.status,
+ sendPlanNodeResp.message);
if (sendPlanNodeResp.getStatus() == null) {
throw new FragmentInstanceDispatchException(
RpcUtils.getStatus(
@@ -228,7 +231,10 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
RegionWriteExecutor writeExecutor = new RegionWriteExecutor();
RegionExecutionResult writeResult = writeExecutor.execute(groupId, planNode);
if (!writeResult.isAccepted()) {
- logger.error(writeResult.getMessage());
+ logger.error(
+ "write locally failed. TSStatus: {}, message: {}",
+ writeResult.getStatus(),
+ writeResult.getMessage());
if (writeResult.getStatus() == null) {
throw new FragmentInstanceDispatchException(
RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, writeResult.getMessage()));