FlinkSQL ClickHouse表开发规则
提前在ClickHouse中创建表
Flink作业在ClickHouse中找不到对应表会报错,所以需提前在ClickHouse中创建好对应的表。
Flink写ClickHouse不支持删除操作
由于不支持删除操作,Flink无法对ClickHouse的数据进行回撤。在Flink处理更新数据的时候产生的回撤流就无法在ClickHouse中执行,导致数据结果不对。
同时通过Flink CDC对接上游数据库写ClickHouse的场景也受限,上游数据库如果进行了物理操作,那么ClickHouse中数据无法进行同步删除。