[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355608#comment-16355608 ]
ASF GitHub Bot commented on FLINK-8571: --------------------------------------- Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5424 CC @aljoscha > Provide an enhanced KeyedStream implementation to use ForwardPartitioner > ------------------------------------------------------------------------ > > Key: FLINK-8571 > URL: https://issues.apache.org/jira/browse/FLINK-8571 > Project: Flink > Issue Type: Improvement > Reporter: Nagarjun Guraja > Assignee: Stefan Richter > Priority: Major > > This enhancement would help in modeling problems with pre partitioned input > sources(for e.g. Kafka with Keyed topics). This would help in making the job > graph embarrassingly parallel while leveraging rocksdb state backend and also > the fine grained recovery semantics. -- This message was sent by Atlassian JIRA (v7.6.3#76005)