更新时间:2024-12-11 GMT+08:00

FlinkSQL ClickHouse表开发规则

提前在ClickHouse中创建表

Flink作业在ClickHouse中找不到对应表会报错,所以需提前在ClickHouse中创建好对应的表。

Flink写ClickHouse不支持删除操作

由于不支持删除操作,Flink无法对ClickHouse的数据进行回撤。在Flink处理更新数据的时候产生的回撤流就无法在ClickHouse中执行,导致数据结果不对。

同时通过Flink CDC对接上游数据库写ClickHouse的场景也受限,上游数据库如果进行了物理操作,那么ClickHouse中数据无法进行同步删除。