Roman Khachatryan created FLINK-19855:
-----------------------------------------
Summary: Incompatible semantics of channelIndex in
UnionInputGate.resumeConsumption and its clients
Key: FLINK-19855
URL: https://issues.apache.org/jira/browse/FLINK-19855
Project: Flink
Issue Type: Bug
Components: Runtime / Network
Affects Versions: 1.11.2, 1.12.0
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
Fix For: 1.12.0
Given only channelIndex for resumeConsumption, UnionInputGate has to guess
which wrapped input gate this channel belongs to.
For that, UnionInputGate expects channelIndex with an inputGate offset.
However, some clients (e.g. AlignedController) pass channel index without
offset.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
