[FLINK-6400] Lack of protection accessing masterHooks in CheckpointCoordinator#triggerCheckpoint

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.3.0
• Assignee: Stephan Ewen
• Reporter: Ted Yu
• Created: 27/Apr/17 15:54
• Updated: 27/Apr/17 21:31
• Resolved: 27/Apr/17 21:27

Description

Here is related code:

    synchronized (triggerLock) {
...
      try {
        List<MasterState> masterStates = MasterHooks.triggerMasterHooks(masterHooks.values(),

masterHooks is protected by lock in other methods while triggerLock is only used in CheckpointCoordinator#triggerCheckpoint()