[FLINK-19338] New source interface cannot unregister unregistered source

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.2, 1.12.0
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Common
• Assignee: Arvid Heise
• Reporter: Arvid Heise
• Created: 22/Sep/20 05:17
• Updated: 22/Jun/21 14:06
• Resolved: 25/Oct/20 19:01

Description

When a source subtask fails before the respective reader is registered in SourceCoordinatorContext, unregistering fails as it explicitly verifies that the reader has been registered before.

The solution is to drop the assumption that all readers are registered when cleaning up subtasks.