?????? flink 1.9 ????????????????

star Wed, 03 Jun 2020 18:59:26 -0700

????????????????????????????append??????????????state?????????????????? 
distinct????????????append??????
????????????????????????append??????????????????????????????????????????????????????????????????????????????????????????????????????????????





------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"LakeShen"<[email protected]&gt;;
????????:&nbsp;2020??6??4??(??????) ????9:45
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.9 ????????????????



Hi,

RetractStream ???????????????? kafka ???????? kafka ?? Append ??????

?????????????????????????????? T ???????????????????? T?????????????????????? 
kafka???????????????? kafka topic??

Best,
LakeShen

star <[email protected]&gt; ??2020??6??3?????? ????4:31??????

&gt; ????????????????
&gt; ????????????????????????????????????????
&gt; ??????select year,month,day,province,sub_name,sum(amount),count(*) as cou
&gt; from mytable group by year,month,day,province,sub_name;
&gt;
&gt;
&gt; ?????????????????????????????? ?????????? ??????
&gt; 
????????????????????????????????????????????kafka??????????????????????????????????????topic??????table????????????????????????
&gt;
&gt;
&gt; ??????????????????????table??
&gt;
&gt;
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"godfrey he"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??6??3??(??????) ????3:40
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: flink 1.9 ????????????????
&gt;
&gt;
&gt;
&gt; hi star,
&gt; Flink 1.11 ???????????? table source ???? retract ??????update ??????
&gt; ???????? Debezium format??Canal format [1]??????????????????????????????
&gt;
&gt;
&gt; Best,
&gt; Godfrey
&gt;
&gt; [1]
&gt;
&gt; 
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=147427289#FLIP105:SupporttoInterpretChangeloginFlinkSQL(IntroducingDebeziumandCanalFormat)-CanalFormat
&gt;
&gt;
&gt; 1048262223 <[email protected]&amp;gt; ??2020??6??3?????? ????2:59??????
&gt;
&gt; &amp;gt; Hi
&gt; &amp;gt; Flink ??RetractStream
&gt; &amp;gt;
&gt; 
????????sink????update????kafka????????????????????update????????????sink??kafka??????????????RetractStream????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; Best,
&gt; &amp;gt; Yichao Yang
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
&gt; &amp;gt; ??????:&amp;amp;nbsp;"star"<[email protected]&amp;amp;gt;;
&gt; &amp;gt; ????????:&amp;amp;nbsp;2020??6??3??(??????) ????2:47
&gt; &amp;gt; 
??????:&amp;amp;nbsp;"[email protected]"<[email protected]
&gt; &amp;amp;gt;;
&gt; &amp;gt;
&gt; &amp;gt; ????:&amp;amp;nbsp;flink 1.9 ????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; 
??????????????????????????????????????????????????????toRetractStream????????kafka??????????????????????????????????????????????????
&gt; &amp;gt; ??????????kafka??????????????????flink 
??RetractStream????????????????????????????????????????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ????

?????? flink 1.9 ????????????????

回复