[
https://issues.apache.org/jira/browse/FLINK-20202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20202.
---------------------------
Resolution: Fixed
Merged to master(1.12.0) via 92ce4952c73ba05e7ffbf1059b6af30adc085cda
> Add 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
> Assignee: Huang Xingbo
> Priority: Major
> Labels: pull-request-available
> 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)
