This is an automated email from the ASF dual-hosted git repository.
mbutrovich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
The following commit(s) were added to refs/heads/main by this push:
new 91f0f7b13 fix: reduce granularity of metrics updates in
IcebergFileStream. (#3050)
91f0f7b13 is described below
commit 91f0f7b139b2f73baaeb529c2a9d3dc4ac5b3c62
Author: Matt Butrovich <[email protected]>
AuthorDate: Tue Jan 6 18:53:51 2026 -0500
fix: reduce granularity of metrics updates in IcebergFileStream. (#3050)
---
native/core/src/execution/operators/iceberg_scan.rs | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git a/native/core/src/execution/operators/iceberg_scan.rs
b/native/core/src/execution/operators/iceberg_scan.rs
index ff6648850..ef2ad63e0 100644
--- a/native/core/src/execution/operators/iceberg_scan.rs
+++ b/native/core/src/execution/operators/iceberg_scan.rs
@@ -369,11 +369,7 @@ impl IcebergFileStream {
}
}
- match ready!(self
- .metrics
- .baseline
- .record_poll(current.poll_next_unpin(cx)))
- {
+ match ready!(current.poll_next_unpin(cx)) {
Some(result) => {
// Stop time_scanning_until_data on first batch
(idempotent)
self.metrics.file_stream.time_scanning_until_data.stop();
@@ -428,7 +424,7 @@ impl Stream for IcebergFileStream {
self.metrics.file_stream.time_processing.start();
let result = self.poll_inner(cx);
self.metrics.file_stream.time_processing.stop();
- result
+ self.metrics.baseline.record_poll(result)
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
