From 4066c630785e44f66a446a63e6d52c7faf964544 Mon Sep 17 00:00:00 2001 From: jizezhang Date: Sun, 16 Nov 2025 08:19:41 -0800 Subject: [PATCH] fix: track elapsed_compute for file stream --- datafusion/datasource/src/file_stream.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/datafusion/datasource/src/file_stream.rs b/datafusion/datasource/src/file_stream.rs index 0568b4cc4e5f..1593e57a482c 100644 --- a/datafusion/datasource/src/file_stream.rs +++ b/datafusion/datasource/src/file_stream.rs @@ -115,6 +115,7 @@ impl FileStream { /// Since file opening is mostly IO (and may involve a /// bunch of sequential IO), it can be parallelized with decoding. fn start_next_file(&mut self) -> Option)>> { + let _timer = self.baseline_metrics.elapsed_compute().timer(); let part_file = self.file_iter.pop_front()?; let partition_values = part_file.partition_values.clone(); @@ -213,6 +214,7 @@ impl FileStream { Some(Ok(batch)) => { self.file_stream_metrics.time_scanning_until_data.stop(); self.file_stream_metrics.time_scanning_total.stop(); + let _timer = self.baseline_metrics.elapsed_compute().timer(); let result = self .pc_projector .project(batch, partition_values)