fix notserializable

apache · Jul 14, 2015 · 575a7c8 · 575a7c8
1 parent 27841de
commit 575a7c8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastLeftSemiJoinHash.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/BroadcastLeftSemiJoinHash.scala
@@ -58,7 +58,8 @@ case class BroadcastLeftSemiJoinHash(
           if (!rowKey.anyNull) {
             val keyExists = hashSet.contains(rowKey)
             if (!keyExists) {
-              hashSet.add(rowKey)
+              // rowKey may be not serializable (from codegen)
+              hashSet.add(rowKey.copy())
             }
           }
         }