You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Nagarjun Guraja (JIRA)" <ji...@apache.org> on 2018/02/06 18:57:00 UTC

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

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)