[ 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)