[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205778#comment-16205778 ]
Aljoscha Krettek commented on FLINK-7837: ----------------------------------------- This PR contains the fix: https://github.com/apache/flink/pull/4833 > AggregatingFunction does not work with immutable types > ------------------------------------------------------ > > Key: FLINK-7837 > URL: https://issues.apache.org/jira/browse/FLINK-7837 > Project: Flink > Issue Type: Bug > Components: DataStream API > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > Priority: Blocker > Fix For: 1.4.0 > > > Currently {{add()}} has this signature: > {code} > void add(IN value, ACC accumulator); > {code} > meaning that a value can only be added to an accumulator by modifying the > accumulator. This should be extended to: > {code} > ACC add(IN value, ACC accumulator); > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)