Skip to content

Commit f31b8ad

Browse files
committed
more fixes
1 parent 38c7449 commit f31b8ad

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/GeneratedAggregate.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ case class GeneratedAggregate(
127127
set)
128128

129129
case CombineSetsAndCount(inputSet) =>
130-
val ArrayType(inputType) = inputSet.dataType
130+
val ArrayType(inputType, _) = inputSet.dataType
131131
val set = AttributeReference("hashSet", inputSet.dataType, nullable = false)()
132132
val initialValue = NewSet(inputType)
133133
val collectSets = CombineSets(set, inputSet)

0 commit comments

Comments
 (0)