Development Rules

Create a ClickHouse Table in Advance

If a Flink job cannot find a specified table in ClickHouse, an error will be reported. You need to ensure that the table has been created in ClickHouse.

Deletion Is Not Supported When Writing ClickHouse Data with Flink

Flink cannot roll back the write of ClickHouse data because the deletion operation is not supported. The withdrawal streams generated when Flink processes updated data cannot be executed in ClickHouse. As a result, the data processing result is incorrect.

This also affects data deletion when Flink CDC is used to connect to the upstream database to write ClickHouse data. When physical operations are performed on the upstream database, data in ClickHouse cannot be deleted synchronously.