[jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

Shang Yuanchun (Jira)
Dian Fu created FLINK-22297:
-------------------------------

             Summary: Perform early check to ensure that the length of the result is the same as the input for Pandas UDF
                 Key: FLINK-22297
                 URL: https://issues.apache.org/jira/browse/FLINK-22297
             Project: Flink
          Issue Type: Improvement
          Components: API / Python
            Reporter: Dian Fu
            Assignee: Dian Fu


For Pandas UDF, the input type for each input argument is Pandas.Series and the result type is also of type Pandas.Series. Besides, the length of the result should be the same as the inputs. If this is not the case, currently the behavior is unclear. We should perform early check for this and provide a clear error message.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)