va/org/apache/flink/streaming/examples/wordcount/WordCount.java#L98
Best
Yun Tang
From: zhanghao.c...@outlook.com
Sent: Thursday, September 15, 2022 0:03
To: Hailu, Andreas ; user@flink.apache.org
Subject: Re: ExecutionMode in ExecutionConfig
It's added in
Wednesday, September 14, 2022 23:38
To: zhanghao.c...@outlook.com ;
user@flink.apache.org
Subject: RE: ExecutionMode in ExecutionConfig
I can give this a try. Do you know which Flink version does this feature become
available in?
ah
From: zhanghao.c...@outlook.com
Sent: Wednesday, Septembe
I can give this a try. Do you know which Flink version does this feature become
available in?
ah
From: zhanghao.c...@outlook.com
Sent: Wednesday, September 14, 2022 11:10 AM
To: Hailu, Andreas [Engineering] ;
user@flink.apache.org
Subject: Re: ExecutionMode in ExecutionConfig
Could you try
Could you try setting ”execution.batch-shuffle-mode‘=‘ALL_EXCHANGES_PIPELINED’?
Looks like the ExecutionMode in ExecutionConfig does not work for DataStream
APIs.
The default shuffling behavior for a DataStream API in batch mode is
'ALL_EXCHANGES_BLOCKING' where upstream and downst
4, 2022 1:10 AM
To: Hailu, Andreas [Engineering] ;
user@flink.apache.org
Subject: Re: ExecutionMode in ExecutionConfig
https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/execution_mode/<https://urldefense.proofpoint.com/v2/url?u=https-3A__nightlies.apache.org_
mode. This should be used for unbounded jobs that require continuous
incremental ...
nightlies.apache.org
Best,
Zhanghao Chen
From: Hailu, Andreas
Sent: Wednesday, September 14, 2022 7:13
To: user@flink.apache.org
Subject: ExecutionMode in ExecutionConfig
