[jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

Shang Yuanchun (Jira)
Fabian Hueske created FLINK-8013:
------------------------------------

             Summary: Check of AggregateFunction merge function signature is too strict.
                 Key: FLINK-8013
                 URL: https://issues.apache.org/jira/browse/FLINK-8013
             Project: Flink
          Issue Type: Bug
          Components: Table API & SQL
    Affects Versions: 1.4.0
            Reporter: Fabian Hueske
            Assignee: Fabian Hueske


The {{AggregationCodeGenerator}} checks that a user-defined {{AggregateFunction}} implements all required methods. However, the check for the {{merge(accumulator: ACC, its: java.lang.Iterable\[ACC\]): Unit}} method is too strict and rejects valid UDAGGs.

This happens for more complex accumulators such as {{Array\[org.apache.flink.api.java.tuple.Tuple2\[java.lang.Integer, java.lang.Float\]\]}} because generic types are lost such that the check of the argument types of {{merge}} fails.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)