This is an automated email from the ASF dual-hosted git repository.

avantgardnerio pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion-ballista.git


The following commit(s) were added to refs/heads/main by this push:
     new c88051266 fix(core): unbreak main — set partition: None on 
OperatorMetric literals (#2254)
c88051266 is described below

commit c88051266c13072dbc4e9cd7972b806815b2f15d
Author: Brent Gardner <[email protected]>
AuthorDate: Sat Aug 8 07:23:31 2026 -0600

    fix(core): unbreak main — set partition: None on OperatorMetric literals 
(#2254)
    
    PR #2038 added `optional uint32 partition = 16` to `OperatorMetric` in
    the proto. PR #2042 was based on pre-#2038 main and added a test with
    three `OperatorMetric { … }` struct literals that don't set `partition`.
    The merge of #2042 skipped a rebase, so the combined tree stopped
    compiling on main (E0063 at 338, 341, 356).
    
    The other three literals in this file (394, 398, 414) already set
    `partition: None`.
    
    Co-authored-by: Claude Opus 4.7 (1M context) <[email protected]>
---
 ballista/core/src/execution_plans/distributed_explain_analyze.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/ballista/core/src/execution_plans/distributed_explain_analyze.rs 
b/ballista/core/src/execution_plans/distributed_explain_analyze.rs
index 116165280..e580c219f 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,
                         }],
                     }],
                 },


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to