Ufuk Celebi created FLINK-1350:
----------------------------------
Summary: 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
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
(v6.3.4#6332)
