[FLINK-7433] Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Component/s: Runtime / State Backends
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 11/Aug/17 16:30
• Updated: 22/Sep/17 06:23
• Resolved: 22/Sep/17 06:22

Description

              try {
                if (throwable != null) {
                  completed.put(requestId, throwable);
                } else {
                  completed.put(requestId, path);
                }
              } finally {
                inProgress.remove(jobId);
              }

The call to inProgress.remove(jobId) should be protected by lock object.

Issue Links

• duplicates: FLINK-7659 Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest