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)
