You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2020/10/28 11:20:00 UTC

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

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)