wip

Author: matthewgapp

datafusion/core/src/physical_optimizer/coalesce_batches.rs

@@ -126,7 +126,6 @@ impl TreeNode for CoalesceContext {
     }
 }
 
-/// implement Display method for `DistributionContext` struct.
 impl fmt::Display for CoalesceContext {
     fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
         let plan_string = get_plan_string(&self.plan);

datafusion/core/src/physical_optimizer/enforce_distribution.rs

@@ -1614,6 +1614,11 @@ impl fmt::Display for DistributionContext {
     fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
         let plan_string = get_plan_string(&self.plan);
         write!(f, "plan: {:?}", plan_string)?;
+        write!(
+            f,
+            "has_recursive_ancestor: {:?}",
+            self.has_recursive_ancestor,
+        )?;
         for (idx, child) in self.distribution_onwards.iter().enumerate() {
             if let Some(child) = child {
                 write!(f, "idx:{:?}, exec_tree:{}", idx, child)?;