[FLINK-7495] AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.3.4, 1.4.0
• Component/s: API / DataStream
• Assignee: Fang Yong
• Reporter: Ted Yu
• Created: 23/Aug/17 17:30
• Updated: 10/May/18 11:50
• Resolved: 12/Mar/18 15:46

Description

    recoveredStreamElements = context
      .getOperatorStateStore()
      .getListState(new ListStateDescriptor<>(STATE_NAME, inStreamElementSerializer));

Call to AbstractUdfStreamOperator#initializeState() should be added in the beginning

Issue Links

• links to: GitHub Pull Request #4621