Re:?????? flink 1.9 ????????????????

Thu, 04 Jun 2020 02:29:36 -0700 

?????????? ????????json??????????????kafka??????flink 
??????????????????json??table?????? ????json 
????????????????????????????????????????????????????????
?? 2020-06-03 16:31:15??"star" <[email protected]> ??????
>????????????????
>????????????????????????????????????????
>??????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;????????&nbsp;------------------
>??????:&nbsp;"godfrey he"<[email protected]&gt;;
>????????:&nbsp;2020??6??3??(??????) ????3:40
>??????:&nbsp;"user-zh"<[email protected]&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 <[email protected]&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"<[email protected]&amp;gt;;
>&gt; ????????:&amp;nbsp;2020??6??3??(??????) ????2:47
>&gt; 
>??????:&amp;nbsp;"[email protected]"<[email protected]&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; ????

回复