[ https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367422#comment-14367422 ]
ASF GitHub Bot commented on FLINK-1350: --------------------------------------- Github user uce commented on the pull request: https://github.com/apache/flink/pull/471#issuecomment-83049370 Thanks for the comments. I'll address the generateSequence comment and open an issue for the optimizer deadlock detection and pipeline breaking stuff after merging this. > 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 > > 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)