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 <[email protected]> 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()));
