diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java index 1d8919dadcc7..86a380df96d9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java @@ -326,7 +326,10 @@ public ITimeSeriesSchemaInfo next() { private void getNext() throws IOException { nextMatched = null; while (allMatchedNodes.hasNext()) { - IMeasurementMNode node = allMatchedNodes.next(); + final IMeasurementMNode node = allMatchedNodes.next(); + if (node.isPreDeleted()) { + continue; + } Pair, Map> tagAndAttributePair = readTagFile(node.getOffset()); nextMatched =