[ https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Greg Hogan closed FLINK-5890. ----------------------------- Resolution: Fixed Fixed in 524b20f2db70fc4afba3a539fbf249c6d768ab4f > GatherSumApply broken when object reuse enabled > ----------------------------------------------- > > Key: FLINK-5890 > URL: https://issues.apache.org/jira/browse/FLINK-5890 > Project: Flink > Issue Type: Bug > Components: Gelly > Affects Versions: 1.3.0 > Reporter: Greg Hogan > Assignee: Greg Hogan > Fix For: 1.3.0 > > > {{GatherSumApplyIteration.SumUdf.reduce}} can store a value from {{arg1}} in > the new {{Tuple2}} which can be overwritten in {{ReduceDriver}}. We need to > swap {{arg0.f1}} and {{arg1.f1}} when this happens (as done in > {{ReduceDriver}} for the returned results). > {code} > @Override > public Tuple2<K, M> reduce(Tuple2<K, M> arg0, Tuple2<K, M> arg1) throws > Exception { > K key = arg0.f0; > M result = this.sumFunction.sum(arg0.f1, arg1.f1); > return new Tuple2<>(key, result); > } > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)