Skip to content

Commit 41fbd1d

Browse files
committed
Never try and create an empty hash set.
1 parent 050bb97 commit 41fbd1d

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/SparkSqlSerializer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ private[sql] class OpenHashSetSerializer extends Serializer[OpenHashSet[_]] {
133133
val rowSerializer = kryo.getSerializer(classOf[Any]).asInstanceOf[Serializer[Any]]
134134

135135
val numItems = input.readInt()
136-
val set = new OpenHashSet[Any](numItems)
136+
val set = new OpenHashSet[Any](numItems + 1)
137137
var i = 0
138138
while (i < numItems) {
139139
val row = rowSerializer.read(kryo, input, classOf[Any].asInstanceOf[Class[Any]])

0 commit comments

Comments
 (0)