flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ufuk Celebi (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-1350) Add blocking intermediate result partitions
Date Thu, 19 Mar 2015 10:26:39 GMT

     [ https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Ufuk Celebi resolved FLINK-1350.
       Resolution: Implemented
    Fix Version/s: 0.9

Implemented in 9d7acf3.

> Add blocking intermediate result partitions
> -------------------------------------------
>                 Key: FLINK-1350
>                 URL: https://issues.apache.org/jira/browse/FLINK-1350
>             Project: Flink
>          Issue Type: Improvement
>          Components: Distributed Runtime
>            Reporter: Ufuk Celebi
>            Assignee: Ufuk Celebi
>             Fix For: 0.9
> The current state of runtime support for intermediate results (see https://github.com/apache/incubator-flink/pull/254
and FLINK-986) only supports pipelined intermediate results (with back pressure), which are
consumed as they are being produced.
> The next variant we need to support are blocking intermediate results (without back pressure),
which are fully produced before being consumed. This is for example desirable in situations,
where we currently may run into deadlocks when running pipelined.
> I will start working on this on top of my pending pull request.

This message was sent by Atlassian JIRA

View raw message