You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by zy...@apache.org on 2022/08/21 10:00:26 UTC
[iotdb] branch master updated: [IOTDB-4195]improve error message of NPE from schema partition (#7068)
This is an automated email from the ASF dual-hosted git repository.
zyk 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 0b463cc0e7 [IOTDB-4195]improve error message of NPE from schema partition (#7068)
0b463cc0e7 is described below
commit 0b463cc0e715d66e78dced000db61bbd00d10c28
Author: Yifu Zhou <ef...@outlook.com>
AuthorDate: Sun Aug 21 18:00:19 2022 +0800
[IOTDB-4195]improve error message of NPE from schema partition (#7068)
[IOTDB-4195]improve error message of NPE from schema partition (#7068)
---
.../java/org/apache/iotdb/commons/partition/SchemaPartition.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java b/node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
index f9ed307c69..949c9f310d 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
@@ -20,7 +20,9 @@ package org.apache.iotdb.commons.partition;
import org.apache.iotdb.common.rpc.thrift.TRegionReplicaSet;
import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
+import org.apache.iotdb.commons.exception.IoTDBException;
import org.apache.iotdb.commons.utils.PathUtils;
+import org.apache.iotdb.rpc.TSStatusCode;
import java.util.ArrayList;
import java.util.HashMap;
@@ -65,6 +67,11 @@ public class SchemaPartition extends Partition {
// TODO return the latest dataRegionReplicaSet for each time partition
String storageGroup = getStorageGroupByDevice(deviceName);
TSeriesPartitionSlot seriesPartitionSlot = calculateDeviceGroupId(deviceName);
+ if (schemaPartitionMap.get(storageGroup) == null) {
+ throw new RuntimeException(
+ new IoTDBException(
+ "Path does not exist. ", TSStatusCode.PATH_NOT_EXIST_ERROR.getStatusCode()));
+ }
return schemaPartitionMap.get(storageGroup).get(seriesPartitionSlot);
}