???????????????? ???????????????????????????????????????? ??????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?? ------------------ ???????? ------------------ ??????: "godfrey he"<[email protected]>; ????????: 2020??6??3??(??????) ????3:40 ??????: "user-zh"<[email protected]>; ????: 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]> ??2020??6??3?????? ????2:59?????? > Hi > Flink ??RetractStream > ????????sink????update????kafka????????????????????update????????????sink??kafka??????????????RetractStream???? > > > Best, > Yichao Yang > > > ------------------&nbsp;????????&nbsp;------------------ > ??????:&nbsp;"star"<[email protected]&gt;; > ????????:&nbsp;2020??6??3??(??????) ????2:47 > ??????:&nbsp;"[email protected]"<[email protected]&gt;; > > ????:&nbsp;flink 1.9 ???????????????? > > > > ???????? > > > > ??????????????????????????????????????????????????????toRetractStream????????kafka?????????????????????????????????????????????????? > ??????????kafka??????????????????flink ??RetractStream???????????????????????????????????????????????????????? > > > > > ????
