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

Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/02/07 15:38:00 UTC

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

    [ 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)