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)
