Never try and create an empty hash set.

xiliu82 · Aug 18, 2014 · 41fbd1d · 41fbd1d
1 parent 050bb97
commit 41fbd1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer.scala
@@ -133,7 +133,7 @@ private[sql] class OpenHashSetSerializer extends Serializer[OpenHashSet[_]] {
     val rowSerializer = kryo.getSerializer(classOf[Any]).asInstanceOf[Serializer[Any]]
 
     val numItems = input.readInt()
-    val set = new OpenHashSet[Any](numItems)
+    val set = new OpenHashSet[Any](numItems + 1)
     var i = 0
     while (i < numItems) {
       val row = rowSerializer.read(kryo, input, classOf[Any].asInstanceOf[Class[Any]])