??????flink sql upsert????????mysql??es??key??????groupby??????????????

Thu, 04 Jun 2020 03:13:26 -0700 

Hi


??????key????????????????????????
https://blog.csdn.net/lp284558195/article/details/104609739
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html#:~:text=The%20minimum%20idle%20state%20retention,kept%20before%20it%20is%20removed.


Best,
Yichao Yang




------------------ ???????? ------------------
??????:&nbsp;"xu yihan"<[email protected]&gt;;
????????:&nbsp;2020??6??4??(??????) ????5:59
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;flink sql upsert????????mysql??es??key??????groupby??????????????




??????????????????
insert into mysql_sink
select 
&nbsp;&nbsp;&nbsp;&nbsp; ID??
&nbsp;&nbsp;&nbsp;&nbsp; amount?? 
&nbsp;&nbsp;&nbsp;&nbsp; ??????
&nbsp;from source
groupby ID??

??????????????id??key????????????????????id??????amount??????????

????????????????calcite??sqlvalidation??select??????????????????????????groupby????????????select??????????
??????????????????????????key??state????????(??????amount????????????double??)??job??????????fail????

????????????????????????????????????key????????????????????????
??????????????????????????????????????????????????????




????????iPhone

回复