Re: 【Flink的shuffle mode】

[Jingsong Li]

Hi,

现在就两种：pipeline和batch

batch的话是block住，直到执行完毕才发给下游的，所以这个shuffle mode一般只对批作业有用。

理论上可以per transformation的来设置，see PartitionTransformation.

Best,
Jingsong

On Sun, Jul 5, 2020 at 10:48 PM 忝忝向仧 <153488...@qq.com> wrote:

> Hi,all:
>
>
> 看Flink源码时候，在应用中使用keyBy后，源码的transformations会有shuffle mode方法，这个shuffle
> mode看是UNDEFINED的。
> 那么，shuffle mode有哪些方式?在应用里面可以设置么?
>
>
> 谢谢.



-- 
Best, Jingsong Lee