2010YOUY01 commented on code in PR #15606:
URL: https://github.com/apache/datafusion/pull/15606#discussion_r2030644638
##########
datafusion/physical-plan/src/repartition/mod.rs:
##########
@@ -510,7 +510,7 @@ impl DisplayAs for RepartitionExec {
writeln!(f, "partitioning_scheme={}", self.partitioning(),)?;
writeln!(
f,
- "output_partition_count={}",
+ "input_partition_count={}",
self.input.output_partitioning().partition_count()
Review Comment:
I think the output partition number is required to display in this node, but
it's not implemented correctly. (or maybe now the planner always set the output
partition the same as the input partition count)
I suggest to change the implementation instead, maybe we can display both
the input and output partition count.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
