Biao Liu created FLINK-13101:
--------------------------------

             Summary: Introduce "blocking after chaining off" property of 
StreamGraph
                 Key: FLINK-13101
                 URL: https://issues.apache.org/jira/browse/FLINK-13101
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: Biao Liu
            Assignee: Biao Liu
             Fix For: 1.9.0


The property "blocking after chaining off" means, if there are some stream 
edges that can not be chained and the shuffle mode of edge is not specified, 
translate these edges into {{BLOCKING}} result partition type.

The reason of introducing it is to satisfy the requirement of Blink batch 
planner. Because the current scheduling strategy is a bit simple. It can not 
support some complex scenarios, like a batch job with resources limited.

To be honest, it's probably a work-around solution. However it's an internal 
implementation, we can replace it when we are able to support batch job by 
scheduling strategy.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to