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

  • 开发
  • 59

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

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

在这里插入图片描述

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

在这里插入图片描述

阅读全部

相关推荐

  2. 方法重写时的原则

    2023-12-19 05:48:03       60 阅读

  4. 方法重载和方法重写的区别

    2023-12-19 05:48:03       50 阅读

  5. 自定义sink

    2023-12-19 05:48:03       36 阅读

  6. 重写setter方法要小心递归调用

    2023-12-19 05:48:03       22 阅读

  7. 方法重写，函数重载，方法覆盖的区别

    2023-12-19 05:48:03       65 阅读

最近更新

  3. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-19 05:48:03       94 阅读

  4. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-19 05:48:03       100 阅读

  9. 在Django里面运行非项目文件

    2023-12-19 05:48:03       82 阅读

  19. Python语言-面向对象

    2023-12-19 05:48:03       91 阅读

  20. 如何分清楚常见的 Git 分支管理策略Git Flow、GitHub Flow 和 GitLab Flow

    2023-12-19 05:48:03       85 阅读

热门阅读

  7. 速盾网络：业务卓越，数字安全的领先者

    2023-12-19 05:48:03       63 阅读

  11. 创建型模式 | 单例模式

    2023-12-19 05:48:03       58 阅读

  13. Qt之图像处理

    2023-12-19 05:48:03       59 阅读

  18. GO语言实现视频分割

    2023-12-19 05:48:03       59 阅读

  22. 压力测试过程中内存溢出（堆溢出、栈溢出、持久代溢出）情况如何解决

    2023-12-19 05:48:03       56 阅读

  26. 前端不同架构的分层设计

    2023-12-19 05:48:03       62 阅读

  28. 开发语言：ArkTS

    2023-12-19 05:48:03       68 阅读

  29. node.js 全部进程挂了，如何使用pm2恢复？

    2023-12-19 05:48:03       58 阅读

  30. Node.js中npm中ws的WebSocket协议的实现

    2023-12-19 05:48:03       57 阅读