Skip to content

Commit 91f0f7b

Browse files
authored
fix: reduce granularity of metrics updates in IcebergFileStream. (#3050)
1 parent edec461 commit 91f0f7b

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

native/core/src/execution/operators/iceberg_scan.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -369,11 +369,7 @@ impl IcebergFileStream {
369369
}
370370
}
371371

372-
match ready!(self
373-
.metrics
374-
.baseline
375-
.record_poll(current.poll_next_unpin(cx)))
376-
{
372+
match ready!(current.poll_next_unpin(cx)) {
377373
Some(result) => {
378374
// Stop time_scanning_until_data on first batch (idempotent)
379375
self.metrics.file_stream.time_scanning_until_data.stop();
@@ -428,7 +424,7 @@ impl Stream for IcebergFileStream {
428424
self.metrics.file_stream.time_processing.start();
429425
let result = self.poll_inner(cx);
430426
self.metrics.file_stream.time_processing.stop();
431-
result
427+
self.metrics.baseline.record_poll(result)
432428
}
433429
}
434430

0 commit comments

Comments
 (0)