diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvaluatePython.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvaluatePython.scala index 520afad287648..7fe3263630820 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvaluatePython.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/python/EvaluatePython.scala @@ -198,7 +198,7 @@ object EvaluatePython { case udt: UserDefinedType[_] => makeFromJava(udt.sqlType) - case other => (obj: Any) => nullSafeConvert(other)(PartialFunction.empty) + case other => (obj: Any) => nullSafeConvert(obj)(PartialFunction.empty) } private def nullSafeConvert(input: Any)(f: PartialFunction[Any, Any]): Any = {