This is an automated email from the ASF dual-hosted git repository. zhihao pushed a commit to branch perf/szh/window_func_limit_k_optimize in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5c2c82d0a5ef0ba4296b28b7eb66f4fde52be782 Author: Sh-Zh-7 <[email protected]> AuthorDate: Fri Feb 20 17:05:51 2026 +0800 Fix pushdown error in row number operator. --- .../relational/planner/WindowFunctionOptimizationTest.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/WindowFunctionOptimizationTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/WindowFunctionOptimizationTest.java index 66b2437e225..ba55d94af9f 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/WindowFunctionOptimizationTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/WindowFunctionOptimizationTest.java @@ -293,12 +293,18 @@ public class WindowFunctionOptimizationTest { * │ └──TableScan * └──ExchangeNode * └──RowNumberNode - * └──TableScan + * └──MergeSortNode + * ├──ExchangeNode + * │ └──TableScan + * └──ExchangeNode + * └──TableScan */ assertPlan(planTester.getFragmentPlan(0), output(collect(exchange(), exchange(), exchange()))); assertPlan(planTester.getFragmentPlan(1), rowNumber(tableScan)); assertPlan(planTester.getFragmentPlan(2), rowNumber(tableScan)); - assertPlan(planTester.getFragmentPlan(3), rowNumber(tableScan)); + assertPlan(planTester.getFragmentPlan(3), rowNumber(mergeSort(exchange(), exchange()))); + assertPlan(planTester.getFragmentPlan(4), tableScan); + assertPlan(planTester.getFragmentPlan(5), tableScan); } @Test
