[FLINK-3392] Unprotected access to elements in ClosableBlockingQueue#size()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Stephan Ewen
• Reporter: Ted Yu
• Created: 11/Feb/16 22:20
• Updated: 12/Feb/16 18:33
• Resolved: 12/Feb/16 18:33

Description

Here is related code:

  public int size() {
    return elements.size();
  }

Access to elements should be protected by lock.lock() / lock.unlock() pair.