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

2023-12-18 19:53:30

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

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

在这里插入图片描述

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

在这里插入图片描述

文章来源:https://blog.csdn.net/weixin_53543905/article/details/135068369
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。