Ted Yu created FLINK-5855:
-----------------------------
Summary: Unprotected access to pendingFilesPerCheckpoint in
BucketingSink
Key: FLINK-5855
URL: https://issues.apache.org/jira/browse/FLINK-5855
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
Priority: Minor
{code}
handlePendingFilesForPreviousCheckpoints(restoredState.pendingFilesPerCheckpoint);
synchronized (restoredState.pendingFilesPerCheckpoint) {
restoredState.pendingFilesPerCheckpoint.clear();
{code}
Lock on pendingFilesPerCheckpoint should be obtained prior to the call to
handlePendingFilesForPreviousCheckpoints().
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
