We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent af84b73 commit e19aa50Copy full SHA for e19aa50
1 file changed
native/core/src/execution/metrics/utils.rs
@@ -68,9 +68,13 @@ pub(crate) fn to_native_metric_node(
68
Some(metrics.aggregate_by_name())
69
};
70
71
- // add metrics
+ // Aggregate metrics by name using DataFusion's aggregate_by_name(), which
72
+ // correctly handles duplicate metric names (e.g. BaselineMetrics registered
73
+ // by both FileStream and ParquetMorselizer on the same ExecutionPlanMetricsSet).
74
+ // The additional_native_plans branch below already does this.
75
node_metrics
76
.unwrap_or_default()
77
+ .aggregate_by_name()
78
.iter()
79
.map(|m| m.value())
80
.map(|m| (m.name(), m.as_usize() as i64))
0 commit comments