[arrow-datafusion] branch master updated: Fix send_time metric (#1421)

[alamb]

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 <danielhe...@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() {