File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/test/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -45,16 +45,16 @@ class PlannerSuite extends FunSuite {
4545 assert(aggregations.size === 2 )
4646 }
4747
48- test(" count distinct is not partially aggregated" ) {
48+ test(" count distinct is partially aggregated" ) {
4949 val query = testData.groupBy(' value )(CountDistinct (' key :: Nil )).queryExecution.analyzed
5050 val planned = HashAggregation (query)
51- assert(planned.isEmpty )
51+ assert(planned.nonEmpty )
5252 }
5353
54- test(" mixed aggregates are not partially aggregated" ) {
54+ test(" mixed aggregates are partially aggregated" ) {
5555 val query =
5656 testData.groupBy(' value )(Count (' value ), CountDistinct (' key :: Nil )).queryExecution.analyzed
5757 val planned = HashAggregation (query)
58- assert(planned.isEmpty )
58+ assert(planned.nonEmpty )
5959 }
6060}
You can’t perform that action at this time.
0 commit comments