这里会例举一些推荐的生产环境配置

  • 使用 Isolated Per Note 模式
  • 使用 Recovery 模式
  • Flink 1.10 就 使用 Interpreter Yarn 模式,Flink 1.11以上版本使用 Yarn Application 模式
  • 启用 Checkpoint

钉钉群+公众号

Flink on Zeppelin 3群钉钉.JPG image.png