flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.
Date Tue, 07 Nov 2017 16:22:00 GMT
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)

Mime
View raw message