[ 
https://issues.apache.org/jira/browse/SPARK-54842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ruifeng Zheng reassigned SPARK-54842:
-------------------------------------

    Assignee: Ruifeng Zheng

> Fix test_arrow_udf_chained_iii in Python-Only MacOS26
> -----------------------------------------------------
>
>                 Key: SPARK-54842
>                 URL: https://issues.apache.org/jira/browse/SPARK-54842
>             Project: Spark
>          Issue Type: Test
>          Components: PySpark, Tests
>    Affects Versions: 4.2.0
>            Reporter: Ruifeng Zheng
>            Assignee: Ruifeng Zheng
>            Priority: Major
>              Labels: pull-request-available
>
> {code:java}
> Caused by: org.apache.spark.api.python.PythonException: Traceback (most 
> recent call last):
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/worker.py", 
> line 3511, in main
>     process()
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/worker.py", 
> line 3502, in process
>     serializer.dump_stream(out_iter, outfile)
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py",
>  line 781, in dump_stream
>     return ArrowStreamSerializer.dump_stream(self, wrap_and_init_stream(), 
> stream)
>            
> ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py",
>  line 120, in dump_stream
>     for batch in iterator:
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py",
>  line 765, in wrap_and_init_stream
>     for packed in iterator:
>   File 
> "/Users/runner/work/spark/spark/python/lib/pyspark.zip/pyspark/worker.py", 
> line 2954, in func
>     for result_batch, result_type in result_iter:
>   File 
> "/Users/runner/work/spark/spark/python/pyspark/sql/tests/arrow/test_arrow_udf_scalar.py",
>  line 930, in <lambda>
>     lambda it: map(lambda x: pa.compute.subtract(x, 1), it),
>                              ^^^^^^^^^^
> AttributeError: module 'pyarrow' has no attribute 'compute' {code}
>  
> https://github.com/apache/spark/actions/runs/20495264978/job/58904792835



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to