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 {
45
45
assert(aggregations.size === 2 )
46
46
}
47
47
48
- test(" count distinct is not partially aggregated" ) {
48
+ test(" count distinct is partially aggregated" ) {
49
49
val query = testData.groupBy(' value )(CountDistinct (' key :: Nil )).queryExecution.analyzed
50
50
val planned = HashAggregation (query)
51
- assert(planned.isEmpty )
51
+ assert(planned.nonEmpty )
52
52
}
53
53
54
- test(" mixed aggregates are not partially aggregated" ) {
54
+ test(" mixed aggregates are partially aggregated" ) {
55
55
val query =
56
56
testData.groupBy(' value )(Count (' value ), CountDistinct (' key :: Nil )).queryExecution.analyzed
57
57
val planned = HashAggregation (query)
58
- assert(planned.isEmpty )
58
+ assert(planned.nonEmpty )
59
59
}
60
60
}
You can’t perform that action at this time.
0 commit comments