sink.update-strategy不生效

[xixer]

flink 1.16.2，版本库master版本的connector

在flink sql中（inert into .. select .. a join b..）未指定或指定sink.update-strategy为update，通过cdc最终写入clickhouse均为insert（重复行）

（ddl中指定了主键

[itinycheng]

@xixer

这个配置我之前测试过是有效的； 可以本地起一个测试的Demo，断点看下原因； 具体实现在ClickHouseUpsertExecutor.addValueToBatch内；

[itinycheng]

不过不建议使用这个功能，因为底层是通过alter..update..进行数据更新的，这个操作比较重； 建议在ClickHouse端 使用 MergeTree + optimize table 来进行数据distinct;