?????? ????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'

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

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

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

hi all:      ??flink 1.12 sql ?? kafka ??msyql ?? kafkadb??kafka ??    ??    insert into db_table_sink select * from  kafka_source_table;    insert i