sunjincheng created FLINK-5105:
----------------------------------
Summary: Improve ReduceState: value put into ReducingState should
always be a copy
Key: FLINK-5105
URL: https://issues.apache.org/jira/browse/FLINK-5105
Project: Flink
Issue Type: Bug
Components: State Backends, Checkpointing
Reporter: sunjincheng
In case of overlapping sliding windows, multiple references are hold on the
same object. If we modify value1 or value2 the results are incorrect. The
value that is put into a ReducingState is always copied. That would allow to
modify and emit one of the two input values (the one which is comes from the
state).
The FoldingState has the same problem.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)