[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358641#comment-16358641 ]
ASF GitHub Bot commented on FLINK-8571: --------------------------------------- Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/5439 > 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)