Flink导入ClickHouse

[levy5307]

https://levy5307.github.io/blog/flink-clickhouse/

说明

当前使用的flinkd-connector-jdbc仅支持Flink DataStream API的方式向ClickHouse导入数据，TableAPI和FlinkSQL尚不支持。

依赖

需要在pom.xml中添加如下依赖，分别为flink connector和clickhouse jdbc驱动

org.apache.flink flink-connector-jdbc_2.11 1.12.7 com.clickhouse clickhouse-jdbc 0.3.2-patch8 http * *

代码示例

在如下代码中，主要介绍了如何通过flink向clickhouse sink中写入数据，source部分可以稍加修改变成kafka等其他服务

public class SinkClickHouse { private static final String CLICKHOUSE_URL =