[ https://issues.apache.org/jira/browse/FLINK-7659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tzu-Li (Gordon) Tai reopened FLINK-7659: ---------------------------------------- > Unprotected access to inProgress in > JobCancellationWithSavepointHandlers#handleNewRequest > ----------------------------------------------------------------------------------------- > > Key: FLINK-7659 > URL: https://issues.apache.org/jira/browse/FLINK-7659 > Project: Flink > Issue Type: Bug > Components: REST > Reporter: Ted Yu > Assignee: Bowen Li > Priority: Major > Fix For: 1.4.0, 1.3.4 > > > Here is related code: > {code} > } finally { > inProgress.remove(jobId); > } > {code} > A little lower, in another finally block, there is: > {code} > synchronized (lock) { > if (!success) { > inProgress.remove(jobId); > {code} > which is correct. -- This message was sent by Atlassian JIRA (v7.6.3#76005)