Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Not A Problem
-
1.4.2, 1.5.0, 1.6.0
-
None
-
None
Description
Here is related code:
handlePendingFilesForPreviousCheckpoints(bucketState.pendingFilesPerCheckpoint);
synchronized (bucketState.pendingFilesPerCheckpoint) {
bucketState.pendingFilesPerCheckpoint.clear();
}
The handlePendingFilesForPreviousCheckpoints() call should be enclosed inside the synchronization block. Otherwise during the processing of handlePendingFilesForPreviousCheckpoints(), some entries of the map may be cleared.