[jira] [Created] (FLINK-921) Channel initialization does not respect JobGraph channel types

[Shang Yuanchun (Jira)]

Ufuk Celebi created FLINK-921:
---------------------------------

             Summary: 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 both InputGate and OutputGate respectively.

When creating a channel, method `getChannelType()` of the abstract Gate class is called instead of the respective descriptor method, which should 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 introduceds runtime lookups of channel receivers in `ChannelManager` as `ChannelManager.register(Task)` does not add it.

introduces runtime lookups for `IN_MEMORY` chann
 



--
This message was sent by Atlassian JIRA
(v6.2#6252)