Skip to content

Commit 72ef664

Browse files
committed
fix pyspark test failure
1 parent 282445c commit 72ef664

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4111,8 +4111,9 @@ case class ArrayExcept(left: Expression, right: Expression) extends ArraySetLike
41114111
""".stripMargin)
41124112
case _ =>
41134113
val genericArrayData = classOf[GenericArrayData].getName
4114+
val et = ctx.addReferenceObj("elementType", elementType)
41144115
("", "Object", "Object", value,
4115-
s"get($i, null)", s"update($pos, $value)", "Object", "Ref",
4116+
s"get($i, $et)", s"update($pos, $value)", "Object", "Ref",
41164117
s"${ev.value} = new $genericArrayData(new Object[$size]);")
41174118
}
41184119

0 commit comments

Comments
 (0)