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
349 stars 149 forks source link

sink.ignore-delete #7

Closed dulangMaster closed 2 years ago

dulangMaster commented 2 years ago

sink.ignore-delete =false issues java.lang.UnsupportedOperationException: Please use prepareStatement(ClickHouseConnection connection) instead. at org.apache.flink.connector.clickhouse.internal.executor.ClickHouseUpsertExecutor.prepareStatement(ClickHouseUpsertExecutor.java:63) at org.apache.flink.connector.clickhouse.internal.ClickHouseBatchOutputFormat.open(ClickHouseBatchOutputFormat.java:63) ... 13 more

itinycheng commented 2 years ago

Thank you for reporting the issue. This is a bug, I will fix it as soon as possible.

itinycheng commented 2 years ago

https://github.com/itinycheng/flink-connector-clickhouse/commit/4ef0612f42e4826a096307d24c026c43f84ba1d4 Bug fixed, but I don’t really recommend using this feature. Please do enough tests before you decide to use this feature.