This is an automated email from the ASF dual-hosted git repository. zhihao pushed a commit to branch perf/szh/push_limit_to_table_scan in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e5454e12fe16251d156546e2f72b55a9420dbc9c Author: Sh-Zh-7 <[email protected]> AuthorDate: Thu Feb 26 15:46:03 2026 +0800 Fix dataPreSortedAndLimited not passed bug. --- .../plan/relational/planner/node/TopKRankingNode.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/TopKRankingNode.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/TopKRankingNode.java index fd41ab4ca70..1dc799611ce 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/TopKRankingNode.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/TopKRankingNode.java @@ -90,13 +90,15 @@ public class TopKRankingNode extends SingleChildProcessNode { @Override public PlanNode clone() { - return new TopKRankingNode( + TopKRankingNode topKRankingNode = new TopKRankingNode( getPlanNodeId(), specification, rankingType, rankingSymbol, maxRankingPerPartition, partial); + topKRankingNode.setDataPreSortedAndLimited(dataPreSortedAndLimited); + return topKRankingNode; } @Override @@ -186,7 +188,7 @@ public class TopKRankingNode extends SingleChildProcessNode { @Override public PlanNode replaceChildren(List<PlanNode> newChildren) { - return new TopKRankingNode( + TopKRankingNode topKRankingNode = new TopKRankingNode( id, Iterables.getOnlyElement(newChildren), specification, @@ -194,6 +196,8 @@ public class TopKRankingNode extends SingleChildProcessNode { rankingSymbol, maxRankingPerPartition, partial); + topKRankingNode.setDataPreSortedAndLimited(dataPreSortedAndLimited); + return topKRankingNode; } @Override @@ -217,7 +221,8 @@ public class TopKRankingNode extends SingleChildProcessNode { rankingType, rankingSymbol, maxRankingPerPartition, - partial); + partial, + dataPreSortedAndLimited); } @Override
