[
https://issues.apache.org/jira/browse/FLINK-2644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2644.
---------------------------------
Resolution: Fixed
Fix Version/s: 1.0.1
Fixed a few versions back...
> State partitioning does not respect the different partitioning of multiple
> inputs
> ---------------------------------------------------------------------------------
>
> Key: FLINK-2644
> URL: https://issues.apache.org/jira/browse/FLINK-2644
> Project: Flink
> Issue Type: Bug
> Components: Streaming
> Reporter: Gyula Fora
> Fix For: 1.0.1
>
>
> Currently state partitioning is only available for one-input stream operators
> and even for those, the partitioning will only depend on the first input.
> This happens because the keyselector used to extract the partitioning key
> from each element is used from the first input stream. We need to make sure
> that for each input stream the corresponding key selector is used.
> To do this, ctx.nextRecord(record), should be extended by adding a parameter
> denoting the index of the input channel which can be used by the partitioner
> to select the appropriate key selector.
> The same mechanics can be extended to allow state partitioning for TwoInput
> stream operators as well.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
