From 81c34391cf1fbd423d863354f1a65c33a60f4479 Mon Sep 17 00:00:00 2001
From: Matthew Gapp <61894094+matthewgapp@users.noreply.github.com>
Date: Wed, 20 Sep 2023 20:24:16 -0700
Subject: [PATCH] wip

---
 datafusion/core/src/physical_optimizer/coalesce_batches.rs   | 1 -
 .../core/src/physical_optimizer/enforce_distribution.rs      | 5 +++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/datafusion/core/src/physical_optimizer/coalesce_batches.rs b/datafusion/core/src/physical_optimizer/coalesce_batches.rs
index 035a2854f80ca..a238099be1ee0 100644
--- a/datafusion/core/src/physical_optimizer/coalesce_batches.rs
+++ b/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);
diff --git a/datafusion/core/src/physical_optimizer/enforce_distribution.rs b/datafusion/core/src/physical_optimizer/enforce_distribution.rs
index bfb3369abaf81..1f9c8c405e25a 100644
--- a/datafusion/core/src/physical_optimizer/enforce_distribution.rs
+++ b/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)?;