From 887fdf751308ce215be0b883eebd4515f71171ea Mon Sep 17 00:00:00 2001 From: discord9 Date: Thu, 16 Jul 2026 10:27:09 +0800 Subject: [PATCH] fix(query): delegate merge sort cardinality effect (#8532) Signed-off-by: discord9 --- src/query/src/dist_plan/merge_sort.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/query/src/dist_plan/merge_sort.rs b/src/query/src/dist_plan/merge_sort.rs index fca81dc4a5..2c8f4d9fd8 100644 --- a/src/query/src/dist_plan/merge_sort.rs +++ b/src/query/src/dist_plan/merge_sort.rs @@ -21,6 +21,7 @@ use std::fmt; use std::sync::Arc; use datafusion::execution::TaskContext; +use datafusion::physical_plan::execution_plan::CardinalityEffect; use datafusion::physical_plan::metrics::MetricsSet; use datafusion::physical_plan::projection::{ProjectionExec, make_with_child, update_ordering}; use datafusion::physical_plan::sorts::sort::SortExec; @@ -253,6 +254,10 @@ impl ExecutionPlan for MergeSortExec { self.inner.partition_statistics(partition) } + fn cardinality_effect(&self) -> CardinalityEffect { + self.inner.cardinality_effect() + } + /// Intentionally keeps DataFusion's generic limit pushdown disabled. /// /// `MergeSortExec` still supports its own global fetch through