Skip to content

Commit 0109705

Browse files
committed
Fix tag index query for pre-deleted timeseries (#18751)
1 parent d6b0680 commit 0109705

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag

‎iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -307,7 +307,10 @@ public ITimeSeriesSchemaInfo next() {
307307
private void getNext() throws IOException {
308308
nextMatched = null;
309309
while (allMatchedNodes.hasNext()) {
310-
IMeasurementMNode<?> node = allMatchedNodes.next();
310+
final IMeasurementMNode<?> node = allMatchedNodes.next();
311+
if (node.isPreDeleted()) {
312+
continue;
313+
}
311314
if (plan.isPrefixMatch()
312315
? pathPattern.prefixMatchFullPath(node.getPartialPath())
313316
: pathPattern.matchFullPath(node.getPartialPath())) {

0 commit comments

Comments
 (0)