Flink的Remote模式会连接一个已经创建好的Flink集群,可以是Flink Standalone 集群,或者是你手动启动的Yarn Session Cluster 或者你在K8S环境上启动的一个Flink Session Cluster 。除了配置FLINK_HOME 和 flink.execution.mode 为 remote 外,还需要配置 flink.execution.remote.host 和 flink.execution.remote.port 来指定JobManager的Rest API 地址(Zeppelin是通过这个Rest api来提交Flink Job的)。如下图所示,
image.png

Interpreter Binding 模式

在Interpreter setting 的页面配置是全局共享的,适用于shared interpreter binding 模式,如果你要连接多个Flink Session Cluster,那么可以用Per User Isolate 模式,或者 Per Note Isolated 模式

Flink Cluster 生命周期

Remote 模式的 Flink Cluster是脱离Zeppelin的管理的,是你在外部启动的Flink Cluster,停止Flink Interpreter并不会销毁Flink Cluster。

视频教程

Flink on Zeppelin 4. Remote模式.mp4 (16.7MB)

钉钉群+公众号

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