flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Monal Daxini (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8571) Provide an enhanced KeyedStream implementation to use ForwardPartitioner
Date Wed, 07 Feb 2018 18:49:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16355877#comment-16355877
] 

Monal Daxini commented on FLINK-8571:
-------------------------------------

Thanks Stefan for the quick turn around time!

Can this patch be applied directly to 1.4, and would this be available in the next 1.4.1 release
as well?

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

Mime
View raw message