diff --git a/src/common/query/src/physical_plan.rs b/src/common/query/src/physical_plan.rs index 1c148020ac..a3e30e1ccf 100644 --- a/src/common/query/src/physical_plan.rs +++ b/src/common/query/src/physical_plan.rs @@ -150,7 +150,7 @@ impl PhysicalPlan for PhysicalPlanAdapter { } fn metrics(&self) -> Option { - Some(self.metric.clone_inner()) + self.df_plan.metrics() } }