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)
