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

Till Rohrmann closed FLINK-11299.
---------------------------------
    Resolution: Abandoned

Closed for inactivity.

> Decide the result partition type dynamically 
> ---------------------------------------------
>
>                 Key: FLINK-11299
>                 URL: https://issues.apache.org/jira/browse/FLINK-11299
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Coordination
>            Reporter: shuai.xu
>            Assignee: shuai.xu
>            Priority: Major
>
> Now, the result partition type is decided when compiling JobGraph at the 
> client. This's to say, whether to output the result of a task to its 
> consumers by PIPELINED or BLOCKING is decided at client and can not be 
> changed any more. However, it is usually seen in batch jobs that a task is 
> configured PIPELINED but its consumers can not be started due to lack of 
> resource, this will lead to failover now. So we proposal to support deciding 
> the result partition type dynamically during runtime according to the 
> resource of cluster and so on to increase the success rate of batch job.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to