diff --git a/src/common/query/src/physical_plan.rs b/src/common/query/src/physical_plan.rs
index fd767a121e..05faf00d5d 100644
--- a/src/common/query/src/physical_plan.rs
+++ b/src/common/query/src/physical_plan.rs
@@ -203,6 +203,10 @@ impl DfPhysicalPlan for DfPhysicalPlanAdapter {
         Ok(Box::pin(DfRecordBatchStreamAdapter::new(stream)))
     }
 
+    fn metrics(&self) -> Option<MetricsSet> {
+        self.0.metrics()
+    }
+
     fn statistics(&self) -> Statistics {
         Statistics::default()
     }