| commit | 09f3510ce8a5c1203128621b57e3aee47549fe6f | [log] [tgz] |
|---|---|---|
| author | cserwen <cserwen@apache.org> | Tue Sep 27 15:31:29 2022 +0800 |
| committer | GitHub <noreply@github.com> | Tue Sep 27 15:31:29 2022 +0800 |
| tree | 4bb37a71f3bccb4f4d0a46e7603f96c8d3c0fa8f | |
| parent | 6430503900e9c2a54008307c6e7814a59e548adb [diff] |
[ISSUE-7430] Fix npe when dispatchRemote (#7439) Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
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 e1d01c9..a76aad7 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
@@ -264,7 +264,8 @@ try { SchemaValidator.validate(insertNode); } catch (SemanticException e) { - throw new FragmentInstanceDispatchException(e); + throw new FragmentInstanceDispatchException( + RpcUtils.getStatus(TSStatusCode.METADATA_ERROR.getStatusCode(), e.getMessage())); } hasFailedMeasurement = insertNode.hasFailedMeasurements(); if (hasFailedMeasurement) {
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 574ac8b..e82b25f 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
@@ -128,6 +128,8 @@ SchemaValidator.validate(insertNode); } catch (SemanticException e) { response.setAccepted(false); + response.setStatus( + RpcUtils.getStatus(TSStatusCode.METADATA_ERROR.getStatusCode(), e.getMessage())); response.setMessage(e.getMessage()); return response; }