itinycheng / flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Apache License 2.0
346 stars 148 forks source link

使用请教 #109

Open yanye666 opened 8 months ago

yanye666 commented 8 months ago

image

初次调研中,我之前是自己通过java实现sink来入库clickhoude的,但是使用这个jar包怎么实现?需要引用什么包吗? 我这样写是看到有issue这样写,但是我会报错,也不会输出数据出来? image

我是想实现上面接着sink 插入到 clickhouse

yanye666 commented 8 months ago

image 1.17.0

itinycheng commented 8 months ago

@yanye666 这个异常和clickhouse没任何关系哈,看起来像 postgres connector 生成的java动态编译异常? 当前master分支在开发中,你可以先用branch release-1.16的代码,编译使用;

yanye666 commented 8 months ago

@yanye666 这个异常和clickhouse没任何关系哈,看起来像 postgres connector 生成的java动态编译异常? 当前master分支在开发中,你可以先用branch release-1.16的代码,编译使用;

另外我想知道如何使用sink这种写法,新手不太理解catalog 与代码并存

yanye666 commented 8 months ago

catalog如何结合我这种写法有知道的吗

itinycheng commented 8 months ago

@yanye666 混合DataStream 和 Table的方法,看下官方的文档:https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/data_stream_api/