(datafusion-ballista) branch main updated: fix: make shuffle exec display consistent (#1299)

[agrove]

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

agrove 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 83db42e4 fix: make shuffle exec display consistent (#1299)
83db42e4 is described below

commit 83db42e4c48ec7bf0584ed3055f47a2c7e19d3cf
Author: Marko Milenković <milenkov...@users.noreply.github.com>
AuthorDate: Thu Aug 28 14:47:19 2025 +0100

    fix: make shuffle exec display consistent (#1299)
---
 ballista/core/src/execution_plans/shuffle_reader.rs     | 8 ++++++--
 ballista/core/src/execution_plans/shuffle_writer.rs     | 4 ++--
 ballista/core/src/execution_plans/unresolved_shuffle.rs | 4 ++--
 3 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/ballista/core/src/execution_plans/shuffle_reader.rs 
b/ballista/core/src/execution_plans/shuffle_reader.rs
index 55dd09de..3cb09ebb 100644
--- a/ballista/core/src/execution_plans/shuffle_reader.rs
+++ b/ballista/core/src/execution_plans/shuffle_reader.rs
@@ -101,10 +101,14 @@ impl DisplayAs for ShuffleReaderExec {
     ) -> std::fmt::Result {
         match t {
             DisplayFormatType::Default | DisplayFormatType::Verbose => {
-                write!(f, "ShuffleReaderExec: partitions={}", 
self.partition.len())
+                write!(
+                    f,
+                    "ShuffleReaderExec: partitioning={:?}",
+                    self.properties.partitioning,
+                )
             }
             DisplayFormatType::TreeRender => {
-                write!(f, "partitions={}", self.partition.len())
+                write!(f, "partitioning={:?}", self.properties.partitioning)
             }
         }
     }
diff --git a/ballista/core/src/execution_plans/shuffle_writer.rs 
b/ballista/core/src/execution_plans/shuffle_writer.rs
index 40dcc12b..0ef3859c 100644
--- a/ballista/core/src/execution_plans/shuffle_writer.rs
+++ b/ballista/core/src/execution_plans/shuffle_writer.rs
@@ -359,12 +359,12 @@ impl DisplayAs for ShuffleWriterExec {
             DisplayFormatType::Default | DisplayFormatType::Verbose => {
                 write!(
                     f,
-                    "ShuffleWriterExec: partitions:{:?}",
+                    "ShuffleWriterExec: partitioning:{:?}",
                     self.shuffle_output_partitioning
                 )
             }
             DisplayFormatType::TreeRender => {
-                write!(f, "partitions={:?}", self.shuffle_output_partitioning)
+                write!(f, "partitioning={:?}", 
self.shuffle_output_partitioning)
             }
         }
     }
diff --git a/ballista/core/src/execution_plans/unresolved_shuffle.rs 
b/ballista/core/src/execution_plans/unresolved_shuffle.rs
index e7d46ba7..8e0ec499 100644
--- a/ballista/core/src/execution_plans/unresolved_shuffle.rs
+++ b/ballista/core/src/execution_plans/unresolved_shuffle.rs
@@ -72,14 +72,14 @@ impl DisplayAs for UnresolvedShuffleExec {
             DisplayFormatType::Default | DisplayFormatType::Verbose => {
                 write!(
                     f,
-                    "UnresolvedShuffleExec: partitions={:?}",
+                    "UnresolvedShuffleExec: partitioning={:?}",
                     self.properties().output_partitioning()
                 )
             }
             DisplayFormatType::TreeRender => {
                 write!(
                     f,
-                    "partitions={:?}",
+                    "partitioning={:?}",
                     self.properties().output_partitioning()
                 )
             }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@datafusion.apache.org
For additional commands, e-mail: commits-h...@datafusion.apache.org