You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by al...@apache.org on 2021/12/08 21:04:51 UTC
[arrow-datafusion] branch master updated: Fix send_time metric (#1421)
This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git
The following commit(s) were added to refs/heads/master by this push:
new 6955a8d Fix send_time metric (#1421)
6955a8d is described below
commit 6955a8d9279bf06311fe0d9d7428854b0601059d
Author: Daniël Heres <da...@gmail.com>
AuthorDate: Wed Dec 8 22:04:45 2021 +0100
Fix send_time metric (#1421)
---
datafusion/src/physical_plan/repartition.rs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/datafusion/src/physical_plan/repartition.rs b/datafusion/src/physical_plan/repartition.rs
index 7073988..55dab6c 100644
--- a/datafusion/src/physical_plan/repartition.rs
+++ b/datafusion/src/physical_plan/repartition.rs
@@ -364,7 +364,7 @@ impl RepartitionExec {
RecordBatch::try_new(input_batch.schema(), columns);
timer.done();
- let timer = r_metrics.repart_time.timer();
+ let timer = r_metrics.send_time.timer();
// if there is still a receiver, send to it
if let Some(tx) = txs.get_mut(&num_output_partition) {
if tx.send(Some(output_batch)).is_err() {