Yue Ma created FLINK-37420:
------------------------------
Summary: AbstractAggregatingState add may return wrong result
Key: FLINK-37420
URL: https://issues.apache.org/jira/browse/FLINK-37420
Project: Flink
Issue Type: Bug
Components: Runtime / State Backends
Affects Versions: 2.0.0
Reporter: Yue Ma
Fix For: 2.0.0
When calling _add()_ in *AbstractAggregatingState* , if the acc is empty, the
value of _updateInternal_ will only be
_this.aggregateFunction.createAccumulator()_ , but it should actually be
this.{_}aggregateFunction.add(value,
this.aggregateFunction.createAccumulator()){_}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
