flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ted Yu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5943) Unprotected access to haServices in YarnFlinkApplicationMasterRunner#shutdown()
Date Wed, 01 Mar 2017 17:34:45 GMT
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)

Mime
View raw message