[jira] [Created] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[Shang Yuanchun (Jira)]

Ted Yu created FLINK-6143:
-----------------------------

             Summary: Unprotected access to this.flink in LocalExecutor#endSession()
                 Key: FLINK-6143
                 URL: https://issues.apache.org/jira/browse/FLINK-6143
             Project: Flink
          Issue Type: Bug
            Reporter: Ted Yu
            Priority: Minor


{code}
  public void endSession(JobID jobID) throws Exception {
    LocalFlinkMiniCluster flink = this.flink;
    if (flink != null) {
{code}
The flink field is not declared volatile and access to this.flink doesn't hold the LocalExecutor.lock



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