[FLINK-3525] Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Assignee: Stephan Ewen
• Reporter: Ted Yu
• Created: 26/Feb/16 17:09
• Updated: 26/Feb/16 18:01
• Resolved: 26/Feb/16 18:01

Description

Here is related code:

  public void close() throws Exception {
    // emit a final watermark

AbstractUdfStreamOperator#close() should be called.