[FLINK-17323] ChannelStateReader rejects requests about unkown channels (Unaligned checkpoints)

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 22/Apr/20 09:01
• Updated: 23/Apr/20 02:36
• Resolved: 23/Apr/20 02:36

Description

ChannelStateReader expects requests only for channels or subpartitions that have state.

In case of upscaling or starting from scratch this behavior is incorrect. It should return NO_MORE_DATA.

Issue Links

• links to: GitHub Pull Request #11861