Use a bogus estimatedRowSize

astefan · Mar 20, 2024 · de3540c · de3540c
1 parent f860c6d
commit de3540c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/PlannerUtils.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/PlannerUtils.java
@@ -87,7 +87,7 @@ public static PhysicalPlan dataNodeReductionPlan(LogicalPlan plan, PhysicalPlan
         if (pipelineBreakers.isEmpty() == false) {
             UnaryPlan pipelineBreaker = (UnaryPlan) pipelineBreakers.get(0);
             if (pipelineBreaker instanceof TopN topN) {
-                return new TopNExec(topN.source(), unused, topN.order(), topN.limit(), 0);
+                return new TopNExec(topN.source(), unused, topN.order(), topN.limit(), 1000);
             } else if (pipelineBreaker instanceof Limit limit) {
                 return new LimitExec(limit.source(), unused, limit.limit());
             } else if (pipelineBreaker instanceof OrderBy order) {