This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch IOTDB-4564 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0adc923c2a491f24332d76e8a3acb6c7cf7d03d2 Author: JackieTien97 <[email protected]> AuthorDate: Fri Sep 30 15:01:44 2022 +0800 Fix NPE while print error log in FragmentInstanceDispatcherImpl --- .../iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java | 2 +- .../org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java | 2 +- 2 files changed, 2 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 a76aad7965..4a39e66018 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 @@ -176,7 +176,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { instance.getRegionReplicaSet().getRegionId()); TSendPlanNodeResp sendPlanNodeResp = client.sendPlanNode(sendPlanNodeReq); if (!sendPlanNodeResp.accepted) { - logger.error(sendPlanNodeResp.getStatus().message); + logger.error(sendPlanNodeResp.message); throw new FragmentInstanceDispatchException(sendPlanNodeResp.getStatus()); } break; diff --git a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java index e82b25f1f1..0a99e47a59 100644 --- a/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java +++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/impl/DataNodeRegionManager.java @@ -105,7 +105,7 @@ public class DataNodeRegionManager { "Something wrong happened while calling consensus layer's write API.", writeResponse.getException()); response.setAccepted(false); - response.setMessage(writeResponse.getException().getMessage()); + response.setMessage(writeResponse.getException().toString()); } return response; }
