Fix

apache · Dec 20, 2019 · 19a36b3 · 19a36b3
1 parent 16d99c7
commit 19a36b3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -541,12 +541,12 @@ class Analyzer(
 
       // If necessary, removes duplicate grouping sets
       val hasDuplicateGroups = selectedGroupByExprs.size !=
-        selectedGroupByExprs.map(_.map(_.semanticHash()).toSet).distinct.size
+        selectedGroupByExprs.map(_.map(_.canonicalized).toSet).distinct.size
       val distinctGroupingSets = if (hasDuplicateGroups) {
-        val groupHashSet = mutable.Set[Set[Int]]()
+        val groupHashSet = mutable.Set[Set[Expression]]()
         val initSet = mutable.ArrayBuffer[Seq[Expression]]()
         selectedGroupByExprs.foldLeft(initSet) { case (b, gs) =>
-          val groupHash = gs.map(_.semanticHash()).toSet
+          val groupHash = gs.map(_.canonicalized).toSet
           if (!groupHashSet.contains(groupHash)) {
             groupHashSet += groupHash
             b += gs