[jira] [Created] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()

[Shang Yuanchun (Jira)]

Ted Yu created FLINK-5943:
-----------------------------

             Summary: Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()
                 Key: FLINK-5943
                 URL: https://issues.apache.org/jira/browse/FLINK-5943
             Project: Flink
          Issue Type: Bug
            Reporter: Ted Yu
            Priority: Minor


{code}
  protected void shutdown(ApplicationStatus status, String msg) {
    // Need to clear the job state in the HA services before shutdown
    try {
      haServices.getRunningJobsRegistry().clearJob(jobGraph.getJobID());
    }
{code}
The access to haServices is without lock protection.
haServices may have been closed.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)