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

Wed, 03 Jun 2020 01:31:45 -0700 

????????????????
????????????????????????????????????????
??????select year,month,day,province,sub_name,sum(amount),count(*) as cou from 
mytable group by year,month,day,province,sub_name;


?????????????????????????????? ?????????? ??????
????????????????????????????????????????????kafka??????????????????????????????????????topic??????table????????????????????????


??????????????????????table??






------------------ ???????? ------------------
??????:&nbsp;"godfrey he"<godfre...@gmail.com&gt;;
????????:&nbsp;2020??6??3??(??????) ????3:40
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



hi star,
Flink 1.11 ???????????? table source ???? retract ??????update ??????
???????? Debezium format??Canal format [1]??????????????????????????????


Best,
Godfrey

[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=147427289#FLIP105:SupporttoInterpretChangeloginFlinkSQL(IntroducingDebeziumandCanalFormat)-CanalFormat


1048262223 <1048262...@qq.com&gt; ??2020??6??3?????? ????2:59??????

&gt; Hi
&gt; Flink ??RetractStream
&gt; 
????????sink????update????kafka????????????????????update????????????sink??kafka??????????????RetractStream????
&gt;
&gt;
&gt; Best,
&gt; Yichao Yang
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"star"<3149768...@qq.com&amp;gt;;
&gt; ????????:&amp;nbsp;2020??6??3??(??????) ????2:47
&gt; 
??????:&amp;nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;flink 1.9 ????????????????
&gt;
&gt;
&gt;
&gt; ????????
&gt;
&gt;
&gt;
&gt; 
??????????????????????????????????????????????????????toRetractStream????????kafka??????????????????????????????????????????????????
&gt; ??????????kafka??????????????????flink 
??RetractStream????????????????????????????????????????????????????????
&gt;
&gt;
&gt;
&gt;
&gt; ????

回复