回复：Blocking or pipelined mode for batch job

= data.map(new MyMapper()); DataSet mapped2 = data.map(new AnotherMapper()); mapped1.join(mapped2).where(...).equalTo(...);--发件人：Ufuk Celebi 发送时间：2016年5月10日(星期二) 17:22收件人：user ; wangzhijiang999 主　题：Re: Blocking or pipelined mode for

Re: Blocking or pipelined mode for batch job

On Tue, May 10, 2016 at 10:56 AM, wangzhijiang999 wrote: >As I reviewed the flink source code, if the ExecutionMode is set > "Pipelined", the DataExechangeMode will be set "Batch" if breaking pipelined > property is true for two input or iteration situation in order to avoid > deadlock. Wh

Blocking or pipelined mode for batch job

Hi ,        As I reviewed the flink source code, if the ExecutionMode is set "Pipelined", the DataExechangeMode will be set "Batch" if breaking pipelined property is true for two input or iteration situation in order to avoid deadlock. When the DataExechangeMode is set "Batch", the ResultPartiti