walkhan
walkhan
@fejxc @itinycheng 测试的时候遇到了,现在有好的办法吗?我现在Flink1.14,看代码update策略代码是实现了,实测不支持
@itinycheng update策略,在1.14代码中看到是有的,实测不支持  那如何做到实时更新(delete和update)
> `sink.update-strategy`的代码我并没合并到release-1.14分支; 不建议在Flink端生成类似update的操作,当前connector对update/delete支持也并不完善; 最好结合ClickHouse端表引擎来解决实际问题,单靠connector不太行; @itinycheng ClickHouse我用了ReplacingMergeTree引擎,如果上游数据更新或者删除了,偶尔还是会出现数据多的问题。那么在1.15中sink.update-strategy能否规避这个问题呢?
@scxwhite 请大佬回复下,谢谢