We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 661e608 commit d0408a1Copy full SHA for d0408a1
sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUDFs.scala
@@ -136,13 +136,13 @@ object EvaluatePython {
136
137
case (a: ArrayData, array: ArrayType) =>
138
val length = a.numElements()
139
- val values = new Array[Any](length)
+ val values = new java.util.ArrayList[Any](length)
140
var i = 0
141
while (i < length) {
142
if (a.isNullAt(i)) {
143
- values(i) = null
+ values.add(null)
144
} else {
145
- toJava(a.get(i), array.elementType)
+ values.add(toJava(a.get(i), array.elementType))
146
}
147
i += 1
148
0 commit comments