如下图：如果用FlinkSQL创建clickhouse的表，会报错！
原因：Flink目前还不支持clickhouse，源码中写死了。只支持Derby，Mysql，Postgres方言。
解决：如果一定要集成，有两个办法：
（1）修改Flink源代码，重新打包，添加修改后的jar包。
（2）使用反射修改DIALECTS静态final属性 。
如果不集成，就先把数据由table转成datastream，再用addsink方法，落地到clickhouse中。
如下图：如果用FlinkSQL创建clickhouse的表，会报错！
原因：Flink目前还不支持clickhouse，源码中写死了。只支持Derby，Mysql，Postgres方言。
解决：如果一定要集成，有两个办法：
（1）修改Flink源代码，重新打包，添加修改后的jar包。
（2）使用反射修改DIALECTS静态final属性 。
如果不集成，就先把数据由table转成datastream，再用addsink方法，落地到clickhouse中。
名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
