[FLINK-19855] Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 28/Oct/20 11:19
• Updated: 22/Jun/21 13:55
• Resolved: 02/Nov/20 08:41

Description

Given channelIndex only, UnionInputGate has to guess which wrapped input
gate this channel belongs to. For that, UnionInputGate expects channel
index with an inputGate offset. This contradicts with the contract of
other resumeConsumption() implementations.
UnionInputGate.resumeConsumption isn't used currently but is planned to
be used in FLINK-19856.

Issue Links

• blocks: FLINK-19856 Add EndOfChannelRecovery rescaling epoch
• links to: GitHub Pull Request #13821