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

[????]

????????????flink-connector-kafka_2.11 ?? flink-connector-jdbc_2.11?? 
??????????????????????????????mysql ?????????????? ?? ?????????????? 
????????????kafka??????????java.sql.BatchUpdateException 
??????????????3???? 
????????sink Kafka ??????????Kafka?? ???????? 'sink.semantic' = 
'exactly-once', ????????consumer ???? --isolation-level read_committed 
????????????????????????????????sink db ??????????sink kafka??????????flink 
??????????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<tsreape...@gmail.com&gt;;
????????:&nbsp;2021??8??26??(??????) ????1:25
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



Hi??

???? statement set ?????????????? insert ?????????????? kafka ???????? db 
???????????????????????????????????? db
???????????????? exception ?????????????????????????? db ?????????? kafka 
????????????????????????

?????????????????????????????????????????????????? db?????????????? db 
???????????? kafka?????????? db ??????????????????????
Flink CDC connector[1]

[1] https://github.com/ververica/flink-cdc-connectors

???? <wukon...@foxmail.com&gt; ??2021??8??26?????? ????12:52??????

&gt; ????????????????statement set[1] ???????????? 
????????StatementSet.addInsertSql ??????sql
&gt; ????????????????execute()????
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 "user-zh"
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <
&gt; fskm...@gmail.com&amp;gt;;
&gt; ????????:&amp;nbsp;2021??8??26??(??????) ????12:36
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: ????flink 1.12 ????????Flink SQL ???? ??sink?? 
??????????????
&gt;
&gt;
&gt;
&gt; ?????? statement set [1] ?? ??
&gt;
&gt; [1]
&gt;
&gt; 
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements
&gt;
&gt; ???? <wukon...@foxmail.com&amp;gt; ??2021??8??26?????? ????11:33??????
&gt;
&gt; &amp;gt; hi all:&amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; ??????????flink 1.12 sql 
???????????? ?????????????????? ????????????
&gt; ???????????? ????kafka
&gt; &amp;gt; ??????????????????msyql ?????? 
????????????????????kafka????????????????db??????????????kafka ??
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;??????????????
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;insert into 
db_table_sink&amp;amp;nbsp;select *
&gt; from&amp;amp;nbsp;
&gt; &amp;gt; kafka_source_table;
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;insert into kafka_table_sink select 
* from
&gt; kafka_source_table;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; &amp;amp;nbsp; ????flink SQL ?????????????? 
??????????????????????db??????????????kafka??????????????flink
&gt; ??????????????