[FLINK-4076] BoltWrapper#dispose() should call AbstractStreamOperator#dispose()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 15/Jun/16 13:49
• Updated: 22/Jun/16 10:13
• Resolved: 22/Jun/16 10:13

Description

  @Override
  public void dispose() {
    this.bolt.cleanup();
  }

AbstractStreamOperator#dispose() should be called first.

Issue Links

• links to: GitHub Pull Request #2111