This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 75ced38605 Minor: make field names match metric name (#11478)
75ced38605 is described below
commit 75ced386055d38ba2719bc1dd4064fa0e87ec1c2
Author: Andrew Lamb <[email protected]>
AuthorDate: Mon Jul 29 06:51:08 2024 -0400
Minor: make field names match metric name (#11478)
---
datafusion/physical-plan/src/repartition/mod.rs | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/datafusion/physical-plan/src/repartition/mod.rs
b/datafusion/physical-plan/src/repartition/mod.rs
index 4870e9e95e..f09324c401 100644
--- a/datafusion/physical-plan/src/repartition/mod.rs
+++ b/datafusion/physical-plan/src/repartition/mod.rs
@@ -415,7 +415,7 @@ struct RepartitionMetrics {
/// Time in nanos to execute child operator and fetch batches
fetch_time: metrics::Time,
/// Time in nanos to perform repartitioning
- repartition_time: metrics::Time,
+ repart_time: metrics::Time,
/// Time in nanos for sending resulting batches to channels.
///
/// One metric per output partition.
@@ -449,7 +449,7 @@ impl RepartitionMetrics {
Self {
fetch_time,
- repartition_time: repart_time,
+ repart_time,
send_time,
}
}
@@ -775,7 +775,7 @@ impl RepartitionExec {
context: Arc<TaskContext>,
) -> Result<()> {
let mut partitioner =
- BatchPartitioner::try_new(partitioning,
metrics.repartition_time.clone())?;
+ BatchPartitioner::try_new(partitioning,
metrics.repart_time.clone())?;
// execute the child operator
let timer = metrics.fetch_time.timer();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
