Skip to content

Commit 70aba2b

Browse files
authored
minor: always time batch_filter even when the result is an empty batch (#11775)
1 parent a0ad376 commit 70aba2b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

datafusion/physical-plan/src/filter.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -380,11 +380,11 @@ impl Stream for FilterExecStream {
380380
Some(Ok(batch)) => {
381381
let timer = self.baseline_metrics.elapsed_compute().timer();
382382
let filtered_batch = batch_filter(&batch, &self.predicate)?;
383+
timer.done();
383384
// skip entirely filtered batches
384385
if filtered_batch.num_rows() == 0 {
385386
continue;
386387
}
387-
timer.done();
388388
poll = Poll::Ready(Some(Ok(filtered_batch)));
389389
break;
390390
}

0 commit comments

Comments
 (0)