You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2020/11/04 12:27:43 UTC
[iotdb] 01/01: solve tag bug
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 <Ja...@foxmail.com>
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());