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)