[FLINK-8415] Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Assignee: vinoyang
• Reporter: Ted Yu
• Created: 11/Jan/18 19:22
• Updated: 28/Feb/19 11:14
• Resolved: 28/Mar/18 06:13

Description

  public void shutdown() {
    running = false;
    recordsToSend.complete(0L);

In other methods, access to recordsToSend is protected by synchronized keyword.

shutdown() should do the same.

Issue Links

• links to: GitHub Pull Request #5724