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/10/08 08:52:58 UTC
[iotdb] 01/01: print status when write failed both in remote and local
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/err_msg_write_1008
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d478cc6995d3bd54525934f835967daa66d2523e
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Sat Oct 8 16:52:46 2022 +0800
print status when write failed both in remote and local
---
.../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()));