Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21587#discussion_r196652632
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/DistributionSuite.scala
---
@@ -41,34 +41,127 @@ class DistributionSuite extends SparkFunSuite {
}
}
- test("HashPartitioning (with nullSafe = true) is the output
partitioning") {
- // Cases which do not need an exchange between two data properties.
+ test("UnspecifiedDistribution and AllTuples") {
--- End diff --
I've reorganized this test suite and added a bunch of new test cases, to
improve the test coverage.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
