Github user yucai commented on a diff in the pull request:
https://github.com/apache/spark/pull/21564#discussion_r196335623
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala ---
@@ -686,6 +686,67 @@ class PlannerSuite extends SharedSQLContext {
Range(1, 2, 1, 1)))
df.queryExecution.executedPlan.execute()
}
+
+ test("SPARK-24556: always rewrite output partitioning in
ReusedExchangeExec " +
+ "and InMemoryTableScanExec") {
+ def checkOutputPartitioningRewrite(
+ plans: Seq[SparkPlan],
--- End diff --
@cloud-fan I still use `Seq`, so I can make
`checkReusedExchangeOutputPartitioningRewrite` and
`checkInMemoryTableScanOutputPartitioningRewrite` simpler. Kindly let me know
if you have better idea.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
