[
https://issues.apache.org/jira/browse/FLINK-921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14029007#comment-14029007 ]
Ufuk Celebi commented on FLINK-921:
-----------------------------------
I just saw that this is not true after all. Before calling {{getChannelType()}} of the Gate, the channel type of the Gate is set from the descriptor.
But the Gate channel type is never used again, so it makes sense to remove this confusing detour after all.
> Channel initialization does not respect JobGraph channel types
> --------------------------------------------------------------
>
> Key: FLINK-921
> URL:
https://issues.apache.org/jira/browse/FLINK-921> Project: Flink
> Issue Type: Bug
> Affects Versions: pre-apache-0.5
> Reporter: Ufuk Celebi
>
> Initialization of input and output channels has been moved with 2db78a8dc1a4664f3e384005d7e07bea594b835b from `RuntimeEnvironment` to `initializeChannels(GateDeploymentDescriptor)` in InputGate and OutputGate respectively.
> When creating a channel, `getChannelType()` of the abstract `Gate` class is called instead of the respective descriptor method, which should actually be called:
> ```
> this.channels[i] = new OutputChannel(this, i, id, connectedId, getChannelType());
> ```
> `getChannelType()` of `Gate` returns `ChannelType.NETWORK`, hence currently all channels are of type `ChannelType.NETWORK`.
> This introduces runtime lookups of channel receivers in `ChannelManager` as `ChannelManager.register(Task)` does not add them at task registration.
>
--
This message was sent by Atlassian JIRA
(v6.2#6252)
Locked
