[jira] [Created] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner

[Shang Yuanchun (Jira)]

Nagarjun Guraja created FLINK-8571:
--------------------------------------

             Summary: 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


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)