diff --git a/ballista/core/src/execution_plans/distributed_explain_analyze.rs b/ballista/core/src/execution_plans/distributed_explain_analyze.rs index 1161652805..e580c219f7 100644 --- a/ballista/core/src/execution_plans/distributed_explain_analyze.rs +++ b/ballista/core/src/execution_plans/distributed_explain_analyze.rs @@ -337,11 +337,13 @@ mod tests { metrics: vec![ OperatorMetric { metric: Some(operator_metric::Metric::OutputRows(4)), + partition: None, }, OperatorMetric { metric: Some(operator_metric::Metric::ElapseTime( 15_000_000, )), + partition: None, }, ], }], @@ -355,6 +357,7 @@ mod tests { operator_desc: "FilterExec: a@0 > 1".to_string(), metrics: vec![OperatorMetric { metric: Some(operator_metric::Metric::OutputRows(2)), + partition: None, }], }], },