使用请教

[yanye666]

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

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

[yanye666]

1.17.0

[itinycheng]

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

[yanye666]

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

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

[yanye666]

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

[itinycheng]

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