[
https://issues.apache.org/jira/browse/FLINK-19855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-19855:
--------------------------------------
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.
was:
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.
> 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.12.0
> Reporter: Roman Khachatryan
> Assignee: Roman Khachatryan
> Priority: Minor
> Labels: pull-request-available
> Fix For: 1.12.0
>
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
