Ted Yu created FLINK-7659:
-----------------------------
Summary: Unprotected access to inProgress in
JobCancellationWithSavepointHandlers#handleNewRequest
Key: FLINK-7659
URL: https://issues.apache.org/jira/browse/FLINK-7659
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
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
(v6.4.14#64029)
