add

Wei-hao-Li · Wei-hao-Li · commit 28f7772ec747 · 2025-12-15T16:30:29.000+08:00
Signed-off-by: Weihao Li &lt;18110526956@163.com&gt;
diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/informationschema/IoTDBCurrentQueriesIT.java
@@ -128,7 +128,7 @@ public void testCurrentQueries() {
         }
         rowNum++;
       }
-      // three rows in the result, 2 FINISHED
+      // two rows in the result, 2 FINISHED
       Assert.assertEquals(2, rowNum);
       Assert.assertEquals(2, finishedQueries);
       resultSet.close();
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/PushPredicateIntoTableScan.java
@@ -472,9 +472,13 @@ public PlanNode visitInformationSchemaTableScan(
                   ? expressions.get(0)
                   : new LogicalExpression(LogicalExpression.Operator.AND, expressions));
         }
+        return node;
       }
 
-      return node;
+      FilterNode filterNode =
+          new FilterNode(queryId.genPlanNodeId(), node, context.inheritedPredicate);
+      context.inheritedPredicate = TRUE_LITERAL;
+      return filterNode;
     }
 
     private SplitExpression splitCurrentQueriesPredicate(Expression predicate) {

Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ public void testCurrentQueries() {`
`128`	`128`	`}`
`129`	`129`	`rowNum++;`
`130`	`130`	`}`
`131`		`- // three rows in the result, 2 FINISHED`
	`131`	`+ // two rows in the result, 2 FINISHED`
`132`	`132`	`Assert.assertEquals(2, rowNum);`
`133`	`133`	`Assert.assertEquals(2, finishedQueries);`
`134`	`134`	`resultSet.close();`
Original file line number	Diff line number	Diff line change
`@@ -472,9 +472,13 @@ public PlanNode visitInformationSchemaTableScan(`
`472`	`472`	`? expressions.get(0)`
`473`	`473`	`: new LogicalExpression(LogicalExpression.Operator.AND, expressions));`
`474`	`474`	`}`
	`475`	`+ return node;`
`475`	`476`	`}`
`476`	`477`
`477`		`- return node;`
	`478`	`+ FilterNode filterNode =`
	`479`	`+ new FilterNode(queryId.genPlanNodeId(), node, context.inheritedPredicate);`
	`480`	`+ context.inheritedPredicate = TRUE_LITERAL;`
	`481`	`+ return filterNode;`
`478`	`482`	`}`
`479`	`483`
`480`	`484`	`private SplitExpression splitCurrentQueriesPredicate(Expression predicate) {`