首先需要说明的是Flink on Zeppelin的Cluster 都是 Session Cluster，没有Per Cluster。
Zeppelin里Flink Cluster 分为2种：

  • Unmanaged Flink Cluster
  • Managed Flink Cluster

Unmanaged Flink Cluster

Unmanaged Flink Cluster 是指这个Flink Cluster不是Zeppelin来管理的。也就是说他不是由Zeppelin启动的，也不能在Zeppelin这边关闭这个集群，比如remote 模式下的 Flink Cluster 对Zeppelin来说就是 Unmanged Cluster。

Managed Flink Cluster

Managed Flink Cluster 是指这个Flink Cluster的生命周期是由Zeppelin来管理。也就是说由Zeppelin来创建并且由Zeppelin来销毁。比如Local模式下的MiniCluster，yarn 模式，yarn-application模式下的Flink Cluster。

启动Flink Cluster

当你第一次run 一个Zeppelin段落的时候就会启动Flink Cluster，所以你会注意到你第一次跑一个段落的时候会比较耗时。

销毁Flink Cluster

Zeppelin支持的Flink Cluster都是 Flink session cluster，所以当你跑完一个Job之后，你会注意到这个Flink Cluster还存活这，如果你要释放的话，需要手动释放，在Zeppelin里只要点击restart flink interpreter就可以销毁Flink Cluster