flink 1.11版中flink JDBCAppendTableLink的替代方法

a5g8bdjr  于 2021-07-15  发布在  Flink
关注(0)|答案(0)|浏览(300)

有什么选择 JDBCAppendTableSink 从flink 1.11版开始?我们正在使用 JDBCAppendTableSink 类将传入的数据存储到postgres,1.11版本的flink已经删除了该类 JDBCAppendTableSink . 我们以前的方法是 JDBCAppendTableSink 在postgres中调用一个存储过程,它最终将记录插入postgres表。有没有办法实现同样的功能?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题