Ted Yu created FLINK-7433:

             Summary: Lack of synchronization accessing inProgress in 
                 Key: FLINK-7433
                 URL: https://issues.apache.org/jira/browse/FLINK-7433
             Project: Flink
          Issue Type: Bug
            Reporter: Ted Yu
            Priority: Minor

              try {
                if (throwable != null) {
                  completed.put(requestId, throwable);
                } else {
                  completed.put(requestId, path);
              } finally {
The call to inProgress.remove(jobId) should be protected by lock object.

This message was sent by Atlassian JIRA

Reply via email to