?????? ????flink 1.12 ????????Flink SQL ???? ??sink?? ??????????????

Wed, 25 Aug 2021 21:52:05 -0700 

????????????????statement set[1] ???????????? ????????StatementSet.addInsertSql 
??????sql ????????????????execute()????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<fskm...@gmail.com&gt;;
????????:&nbsp;2021??8??26??(??????) ????12:36
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ????flink 1.12 ????????Flink SQL ???? ??sink?? ??????????????



?????? statement set [1] ?? ??

[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements

???? <wukon...@foxmail.com&gt; ??2021??8??26?????? ????11:33??????

&gt; hi all:&amp;nbsp;
&gt; &amp;nbsp; &amp;nbsp; ??????????flink 1.12 sql ???????????? 
?????????????????? ???????????? ???????????? ????kafka
&gt; ??????????????????msyql ?????? 
????????????????????kafka????????????????db??????????????kafka ??
&gt; &amp;nbsp; &amp;nbsp;??????????????
&gt; &amp;nbsp; &amp;nbsp;insert into db_table_sink&amp;nbsp;select * 
from&amp;nbsp;
&gt; kafka_source_table;
&gt; &amp;nbsp; &amp;nbsp;insert into kafka_table_sink select * from 
kafka_source_table;
&gt;
&gt;
&gt; &amp;nbsp; ????flink SQL ?????????????? 
??????????????????????db??????????????kafka??????????????flink ??????????????

回复