Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19607#discussion_r152174929
--- Diff: python/pyspark/worker.py ---
@@ -150,7 +150,8 @@ def read_udfs(pickleSer, infile, eval_type):
if eval_type == PythonEvalType.SQL_PANDAS_SCALAR_UDF \
or eval_type == PythonEvalType.SQL_PANDAS_GROUP_MAP_UDF:
- ser = ArrowStreamPandasSerializer()
+ timezone = utf8_deserializer.loads(infile)
--- End diff --
The timezone will be read by the following `ArrowStreamPandasSerializer`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
