how to process deletion on clickhouse
Closed this issue · 1 comments
baisui1981 commented
as checked the document of flink-clickhouse-sink ,I have a question how to execute deletion on Clickhouse , it seems that has not been mentioned
mchernyakov commented
@baisui1981 hi, flink-clickhouse-sink does not have such an option.
It works only with inserts, check here https://github.com/ivi-ru/flink-clickhouse-sink/blob/master/src/main/java/ru/ivi/opensource/flinkclickhousesink/applied/ClickHouseWriter.java#L198 .