Ted Yu created FLINK-5486: ----------------------------- Summary: Lack of synchronization in BucketingSink#handleRestoredBucketState() Key: FLINK-5486 URL: https://issues.apache.org/jira/browse/FLINK-5486 Project: Flink Issue Type: Bug Reporter: Ted Yu
Here is related code: {code} handlePendingFilesForPreviousCheckpoints(bucketState.pendingFilesPerCheckpoint); synchronized (bucketState.pendingFilesPerCheckpoint) { bucketState.pendingFilesPerCheckpoint.clear(); } {code} The handlePendingFilesForPreviousCheckpoints() call should be enclosed inside the synchronization block. Otherwise during the processing of handlePendingFilesForPreviousCheckpoints(), some entries of the map may be cleared. -- This message was sent by Atlassian JIRA (v6.3.4#6332)