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

ASF GitHub Bot updated SPARK-58161:
-----------------------------------
    Labels: pull-request-available  (was: )

> [PYTHON] Standardize PySpark UDF row count mismatch error to use 
> RESULT_ROWS_MISMATCH
> -------------------------------------------------------------------------------------
>
>                 Key: SPARK-58161
>                 URL: https://issues.apache.org/jira/browse/SPARK-58161
>             Project: Spark
>          Issue Type: Improvement
>          Components: PySpark
>    Affects Versions: 4.0.0
>            Reporter: gaurav kumar pandey
>            Priority: Major
>              Labels: pull-request-available
>
> Currently, PySpark Pandas and Arrow UDFs raise a custom 
> SCHEMA_MISMATCH_FOR_PANDAS_UDF error class when the returned result length 
> does not match the input row count. 
> To align with Spark's error standardization efforts, we should migrate this 
> to the standard RESULT_ROWS_MISMATCH error class and remove the redundant 
> SCHEMA_MISMATCH_FOR_PANDAS_UDF from error-conditions.json.
> Proposed Changes:
> 1. Migrate UDF scalar and arrow verification logic in worker.py to raise 
> RESULT_ROWS_MISMATCH with input/output length parameters.
> 2. Retain the old error message format ("Result vector from pandas_udf was 
> not the required length...") in the message string for backward-compatibility 
> with user code that asserts on the exception message.
> 3. Update affected unit tests, documentation guidelines (debugging.rst), and 
> clean up error-conditions.json.



--
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