fix python

prabeesh · Aug 1, 2015 · 77d482f · 77d482f
1 parent e8f6682
commit 77d482f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUDFs.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUDFs.scala
@@ -137,7 +137,7 @@ object EvaluatePython {
     case (a: ArrayData, array: ArrayType) =>
       val values = new java.util.ArrayList[Any](a.numElements())
       a.foreach(array.elementType, (_, e) => {
-        values.add(e)
+        values.add(toJava(e, array.elementType))
       })
       values