Mysql Sink主键冲突

问题描述/异常栈

Caused by: java.lang.ClassNotFoundException:

解决方案

使用 set 'TABLE_NAME.connector.key-fields'='dt,time_field,kpi_key' 指定主键，会自动触发upsert

问题原因

APPEND方式写入，主键冲突。

作者：邓崃翔