Skip to content
Prev Previous commit
fallback to regular udf
  • Loading branch information
xinrong-meng committed Apr 20, 2023
commit ac86bf1f252bfc27f0d097ee6eb0cd6ac77663b3
1 change: 1 addition & 0 deletions python/pyspark/sql/connect/udf.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ def _create_py_udf(
"Arrow optimization for Python UDFs cannot be enabled.",
UserWarning,
)
return regular_udf
else:
return regular_udf

Expand Down
1 change: 1 addition & 0 deletions python/pyspark/sql/udf.py
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,7 @@ def _create_py_udf(
"Arrow optimization for Python UDFs cannot be enabled.",
UserWarning,
)
return regular_udf
else:
return regular_udf

Expand Down