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

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.0
• Component/s: Command Line Client
• Assignee: zhangminglei
• Reporter: Ted Yu
• Created: 21/Mar/17 15:45
• Updated: 02/Oct/19 17:49
• Resolved: 15/Apr/17 17:50

Description

  public void endSession(JobID jobID) throws Exception {
    LocalFlinkMiniCluster flink = this.flink;
    if (flink != null) {

The flink field is not declared volatile and access to this.flink doesn't hold the LocalExecutor.lock

Issue Links

• links to: GitHub Pull Request #3710