tis
tis copied to clipboard
[Clickhouse Sink] 目前不支持Delete 删除功能
trafficstars
目前实现基于: https://github.com/ivi-ru/flink-clickhouse-sink
<dependency>
<groupId>ru.ivi.opensource</groupId>
<artifactId>flink-clickhouse-sink</artifactId>
<version>1.3.3</version>
</dependency>
不支持delete功能实现,
需要切换到,基于Clickhouse JDBC接口的实现上:
<dependency>
<groupId>ru.yandex.clickhouse</groupId>
<artifactId>clickhouse-jdbc</artifactId>
<version>0.3.1</version>
</dependency>
可以参考streamx的实现 https://github.com/streamxhub/streamx-connector/tree/main/flink-connector-clickhouse
或者chunju的实现 https://github.com/DTStack/chunjun/tree/master/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse