Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21564#discussion_r195883713
--- Diff: sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
---
@@ -2270,4 +2270,15 @@ class DataFrameSuite extends QueryTest with
SharedSQLContext {
val mapWithBinaryKey = map(lit(Array[Byte](1.toByte)), lit(1))
checkAnswer(spark.range(1).select(mapWithBinaryKey.getItem(Array[Byte](1.toByte))),
Row(1))
}
+
+ test("SPARK-24556: ReusedExchange should rewrite output partitioning for
RangePartitioning") {
--- End diff --
this is not an end-to-end test, let's put it in `PlannerSuite` and also
test cached table.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
