未验证 提交 0b463cc0 编写于 作者: Y Yifu Zhou 提交者: GitHub

[IOTDB-4195]improve error message of NPE from schema partition (#7068)

[IOTDB-4195]improve error message of NPE from schema partition (#7068)
上级 6389b5bb
...@@ -20,7 +20,9 @@ package org.apache.iotdb.commons.partition; ...@@ -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.TRegionReplicaSet;
import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot; 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.commons.utils.PathUtils;
import org.apache.iotdb.rpc.TSStatusCode;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
...@@ -65,6 +67,11 @@ public class SchemaPartition extends Partition { ...@@ -65,6 +67,11 @@ public class SchemaPartition extends Partition {
// TODO return the latest dataRegionReplicaSet for each time partition // TODO return the latest dataRegionReplicaSet for each time partition
String storageGroup = getStorageGroupByDevice(deviceName); String storageGroup = getStorageGroupByDevice(deviceName);
TSeriesPartitionSlot seriesPartitionSlot = calculateDeviceGroupId(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); return schemaPartitionMap.get(storageGroup).get(seriesPartitionSlot);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册