e.displayText() = DB::Exception: Mutations are not supported by storage Distributed about flink-connector-clickhouse

[itinycheng]

Distributed table don't support update/delete statement, We can directly write data to local table, set conf use-local=true and do some tests.
In addition, we'd better don't use upsert mode but insert to overwrite data in the MergeTree table engine instead.

[hehetown]

Thank you very much. Let's try to replace the upsert mode with insert.

[hehetown]

use-local=true, report error:ClickHouse exception, code: 341, host: 10.233.79.20, port: 8123; Code: 341, e.displayText() = DB::Exception: There was an error on [demo-clickhouse-1-0:9000]: Cannot execute replicated DDL query, maximum retires exceeded (version 21.1.3.32)

I don't know what to do with it. Ask for help..

[itinycheng]

use-local=true, report error:ClickHouse exception, code: 341, host: 10.233.79.20, port: 8123; Code: 341, e.displayText() = DB::Exception: There was an error on [demo-clickhouse-1-0:9000]: Cannot execute replicated DDL query, maximum retires exceeded (version 21.1.3.32)

I don't know what to do with it. Ask for help..

This is an exception thrown by the clickhouse server, you'd better get the more useful info from the server log.
DDL statement is generated under upsert mode, you can do some breakpoint tests to get what DDL executed.