From 77d482f8649091793023b803c189592dd497b50a Mon Sep 17 00:00:00 2001 From: Wenchen Fan Date: Sat, 1 Aug 2015 13:24:38 +0800 Subject: [PATCH] fix python --- .../main/scala/org/apache/spark/sql/execution/pythonUDFs.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 29258d7f69b51..aade2e769ccd6 100644 --- 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