?????? ??Flink??shuffle mode??

Tue, 07 Jul 2020 08:37:33 -0700 

??????????????????????????????????????shuffle_mode???
????????????????????????????????????pipeline????.
??????????????datastream??keyby??????????????????????mode??UNDEFINED???
????.




------------------ ???????? ------------------
??????:&nbsp;"Jingsong Li"<[email protected]&gt;;
????????:&nbsp;2020??7??6??(??????) ????12:19
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ??Flink??shuffle mode??



pipeline????????????????????buffer????????
batch??buffer????????????????????????

????????pipeline
????????pipeline(??????????)??????????batch(????????????????????????????)

Best,
Jingsong

On Mon, Jul 6, 2020 at 12:16 PM ???????? <[email protected]&gt; wrote:

&gt;
&gt; 
????????datasream????????????pipeline,??????????batch????????????????shuffle??????????????shuffle????????????????????????.??????????????shuffle??????????shuffle????????????????shuffle????????????????????????????????????????shuffle????????????????????????????????shuffle????????????????????
&gt;
&gt;
&gt;
&gt; ????????iPhone
&gt;
&gt;
&gt; ------------------ ???????? ------------------
&gt; ??????: Jingsong Li <[email protected]&amp;gt;
&gt; ????????: 2020??7??6?? 11:03
&gt; ??????: user-zh <[email protected]&amp;gt;
&gt; ????: ????????Flink??shuffle mode??
&gt;
&gt;
&gt;
&gt; Hi,
&gt;
&gt; ????????????pipeline??batch
&gt;
&gt; batch??????block??????????????????????????????????????shuffle 
mode????????????????????
&gt;
&gt; ??????????per transformation??????????see PartitionTransformation.
&gt;
&gt; Best,
&gt; Jingsong
&gt;
&gt; On Sun, Jul 5, 2020 at 10:48 PM ???????? <[email protected]&amp;gt; wrote:
&gt;
&gt; &amp;gt; Hi,all:
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
??Flink??????????????????????keyBy??????????transformations????shuffle 
mode??????????shuffle
&gt; &amp;gt; mode????UNDEFINED????
&gt; &amp;gt; ??????shuffle mode????????????????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ????.
&gt;
&gt;
&gt;
&gt; --
&gt; Best, Jingsong Lee



-- 
Best, Jingsong Lee

回复