Huang Xingbo created FLINK-20202:
------------------------------------
Summary: Add the Check of Unsupported Result Type in Pandas UDAF
Key: FLINK-20202
URL:
https://issues.apache.org/jira/browse/FLINK-20202 Project: Flink
Issue Type: Improvement
Components: API / Python
Reporter: Huang Xingbo
Fix For: 1.12.0
Currently the return type of Pandas UDAF should be a primitive data type, and the returned scalar can be either a python primitive type, e.g., {{int}} or {{float}} or a numpy data type, e.g., {{numpy.int64}} or {{numpy.float64}}. {{Any}} should ideally be a specific scalar type accordingly. We will add related DataType check and throw a more readable exception for unsupported DataTypes. What's more, we will add related notes in docs.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)