search

itinycheng / flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Apache License 2.0
363 stars 154 forks source link

cdc 写入 ck 的时候，是否支持先按照主键删除数据，在插入数据吗 #87

Closed mengfanyu closed 1 year ago

mengfanyu commented 1 year ago

sink.update-strategy=update 时，表有 PARTITION BY 字段 不支持更新，执行update 会报错。

itinycheng commented 1 year ago

代码中生成alter语句是有对partition key进行排除的； 你可以测试找下具体原因，如有疑问请提供上下文和异常栈信息；

mengfanyu commented 1 year ago

image 'sink.partition-key' = 'ORGANIZATION_CODE', 加了参数，更新时测试没有排除

mengfanyu commented 1 year ago

代码中生成alter语句是有对partition key进行排除的； 你可以测试找下具体原因，如有疑问请提供上下文和异常栈信息；

'sink.partition-key' = 'ORGANIZATION_CODE' 加了之后，在 生成 alter table 时没有去除此字段，是配置的不正确吗，请指导一下，谢谢

mengfanyu commented 1 year ago

解决了，ddl PARTITIONED BY 使用错误