【Flink-Bug】Flink 自定义 Sink 重写 RichSinkFunction 方法时重复调用 open 的解决方案

Flink 自定义 RichinkFunction 时可能会重写 open 方法进行某些连接的初始化操作，但是会出现重复调用 open 方法的问题，如：MQ，如果重复调用 open 进行初始化操作，就会出现 group 重复的问题。

解决方案：自定义并行度，让 open 方法只调用一次。

服务器托管，北京服务器托管，服务器租用 http://www.f服务器托管网wqtg.net

相关推荐: .net core微服务之服务发现

一：nacos 　　https://nacos.io/docs/latest/what-is-nacos/ 　　https://github.com/alibaba/nacos 二：consul 　　https://developer.hashicorp.co…