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)