本文为您介绍如何查看和修改作业状态,以及不同状态所代表的含义。
查看作业状态
- 登录实时计算管理控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,选择应用 > 作业运维。
- 单击目标作业名称。
- 在作业总览页签,查看作业状态信息。页面左上角会显示两种作业状态:
- 期望状态
状态 说明 RUNNING 按作业配置,启动作业。 CANCELLED 停止任何正在运行的作业。 SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。 - 当前状态
状态 说明 RUNNING 按作业配置定义,启动作业。 CANCELLED 停止任何正在运行的作业。 SUSPENDED 先对当前运行的作业创建Savepoint,再停止作业。 FINISHED 作业运行完成。 TRANSITIONING 作业处于向期望状态的过度阶段。 FAILED 作业向期望状态转换失败,需要手动处理。 ClusterUnreachable VVP无法访问JM(JobManager),获取不到Job的状态。
说明 单击启动后,作业的期望状态会立刻变成RUNNING,当前状态会变成TRANSITIONING,并显示作业启动进度。前端开发平台VVP(Ververica Platform)会保证Flink作业最终达到期望状态。如果Flink作业状态正在从某个状态变成期望状态的过程中,而作业的最终期望状态发生了改变,作业会先到达最初的期望状态,再转换为最终的期望状态。
- 期望状态
修改作业状态
- 登录实时计算控制台。
- 在Flink全托管页签,单击目标工作空间操作列下的开发控制台。
- 在左侧导航栏上,选择应用 > 作业运维。
- 单击目标作业名称。
- 单击作业总览页签,进入作业详情页面。
- 根据需要单击以下按钮,修改作业状态。其中,每个按钮含义如下表所示。
操作名称 说明 暂停 暂停作业,先对当前运行的作业创建Savepoint,再停止作业。暂停作业需要具备以下两个条件: - Savepoint地址配置完成。如果Savepoint地址没有配置,暂停操作将直接停止作业,导致作业状态丢失。
- Savepoint操作成功。
停止 停止作业。 诊断 系统会根据收集到的瞬时作业信息(例如Failover等)和常见的作业诊断规则,给您一些简单指导意见。 Savepoint 创建一个当前时刻的Savepoint。 说明 请先完成Savepoint地址配置,否则Savepoint会失败。编辑 修改作业基础配置或高级配置。 删除 删除作业。只能删除当前状态不为RUNNING的作业。