Skip to content

Flink集群管理

wangqi edited this page Jun 14, 2022 · 8 revisions

Flink集群管理

release 管理

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

集群和任务

集群根据资源和部署方式

standalone,yarn,native kubernetes

session,per-job,application

集群状态。运行中,停止

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

任务信息:配置,jar,sql+udf

任务实例。

配置管理

管理功能。支持版本管理

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

配置内容:

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

jar 任务管理

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

sql 任务管理

Clone this wiki locally