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)
