Ted Yu created FLINK-4534:
-----------------------------
Summary: Lack of synchronization in BucketingSink#restoreState()
w.r.t. state.bucketStates
Key: FLINK-4534
URL: https://issues.apache.org/jira/browse/FLINK-4534
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Iteration over state.bucketStates is protected by synchronization in other
methods, except for the following in restoreState():
{code}
for (BucketState<T> bucketState : state.bucketStates.values()) {
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
