Ted Yu created FLINK-7433: ----------------------------- Summary: Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers Key: FLINK-7433 URL: https://issues.apache.org/jira/browse/FLINK-7433 Project: Flink Issue Type: Bug Reporter: Ted Yu Priority: Minor
{code} try { if (throwable != null) { completed.put(requestId, throwable); } else { completed.put(requestId, path); } } finally { inProgress.remove(jobId); } {code} The call to inProgress.remove(jobId) should be protected by lock object. -- This message was sent by Atlassian JIRA (v6.4.14#64029)