?????? ????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_sinkselect * from kafka_source_table; insert into