This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch TagBugMaster in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 78b91c96b15a3fea2d9ae632ed53d5d021e9ae3d Author: JackieTien97 <[email protected]> AuthorDate: Wed Nov 4 20:27:14 2020 +0800 solve tag bug --- server/src/main/java/org/apache/iotdb/db/metadata/MManager.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java index 8d244dc..cd177db 100644 --- a/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java +++ b/server/src/main/java/org/apache/iotdb/db/metadata/MManager.java @@ -821,6 +821,9 @@ public class MManager { List<MeasurementMNode> allMatchedNodes = new ArrayList<>(); if (plan.isContains()) { for (Entry<String, Set<MeasurementMNode>> entry : value2Node.entrySet()) { + if (entry.getKey() == null || entry.getValue() == null) { + continue; + } String tagValue = entry.getKey(); if (tagValue.contains(plan.getValue())) { allMatchedNodes.addAll(entry.getValue()); @@ -828,6 +831,9 @@ public class MManager { } } else { for (Entry<String, Set<MeasurementMNode>> entry : value2Node.entrySet()) { + if (entry.getKey() == null || entry.getValue() == null) { + continue; + } String tagValue = entry.getKey(); if (plan.getValue().equals(tagValue)) { allMatchedNodes.addAll(entry.getValue());
