[FLINK-18039] Change SourceCoordinator to handle resetToCheckpoint() call after started.

• Type: Sub-task
• Status: Resolved
• Priority: Blocker
• Resolution: Implemented
• Fix Version/s: 1.11.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 30/May/20 02:37
• Updated: 16/Jun/20 06:16
• Resolved: 15/Jun/20 17:40

Description

Right now the SourceCoordinator assumes that resetToCheckpoint() is only called before start() is called. We need to change the SourceCoordinator to handle the case when resetToCheckpoint() is invoked after the SourceCoordinator has started.

Issue Links

• links to: GitHub Pull Request #12510