Flink集群管理

Flink集群管理

release 管理

• 查看 release 列表
• 加载 release
• 上传 release
• 下载 release

集群和任务

集群根据资源和部署方式

standalone，yarn，native kubernetes

session，per-job，application

集群状态。运行中，停止

集群配置和根据实例拉起的集群

任务信息：配置，jar，sql+udf

任务实例。

集群

资源管理。

standalone，yarn，native kubernetes 下所需要的资源信息。

如 yarn 模式下需要的 hadoop 配置信息，native kubernetes 模式下需要的 kubeconfig 和 context 信息。

配置管理

集群的配置信息。如 checkpoint，savepoint，state backends，ha，resource

集群管理

根据资源，部署模式和配置信息，拉起一个集群，关闭集群等

配置管理

管理功能。支持版本管理

• 新增配置。支持默认配置
• 修改配置。
• 删除配置。

配置内容：

• checkpoint & savepoint
• 内存
• ha，重启
• 日志

jar 任务管理

• 创建任务
• 修改任务
• 提交任务
• 停止任务
• savepoint。创建，销毁
• 删除任务

sql 任务管理