作业启动 - 实时计算Flink版

前提条件

其他阿里云账号或RAM用户共同使用Flink全托管产品时，需要为阿里云账号或RAM用户授权，以进行作业启动等相关操作，详情请参见作业操作账号授权。

仅实时计算引擎VVR4.0.11及以上版本支持State兼容性检测。
仅实时计算引擎VVR4.0.8及以上版本的界面上支持设置启动位点。
作业启动界面指定的读取数据时间优先级高于作业DDL代码里设置的startTime。即如果您在作业DDL和作业启动界面都指定了读取数据时间，则作业启动界面指定的读取数据时间生效。
说明
- 不是所有的Connector都支持startTime，详情请参见各Connector WITH参数是否包含startTime，例如日志服务SLS WITH参数。
- 只有全新启动作业并指定了startTime，startTime才生效。如果基于Checkpoint或Savepoint启动作业，即使指定了startTime，startTime也不会生效。

在启动作业时，如果您选择从最新、当前作业的历史快照、其他作业的快照启动作业时，系统会进行State兼容性检测。兼容性检测详情请参见Flink State兼容性参考。

进入目标流作业启动页面。
1. 登录实时计算控制台。
2. 在Flink全托管页签，单击对应工作空间操作列下的控制台。
3. 在左侧导航栏上，选择应用 > 作业运维。
4. 在作业模式下拉列表中，选择流作业。
在目标流作业名称右侧，单击操作列中的启动。

在作业启动配置对话框，进行资源设置和基础设置。

填写基础配置信息。


配置项	说明
启动策略	支持以下几种启动策略：全新启动（无状态）：当您是新上线作业，可以选择全新启动。此外，如果无法复用State，也可以全新启动。从最新状态恢复：从快照或者系统检查点的最新状态进行恢复。从当前作业的快照恢复：从本作业历史上的某个快照恢复业务。选择此策略后，您需要选择对应的快照。从其他作业的快照恢复：从其他作业的快照恢复作业，常用于克隆作业后的双跑测试。选择此策略后，您需要依次选择目标作业和目标快照。重要选择此选项时，如果作业逻辑修改出现状态不兼容，则可能导致作业启动失败。
指定读取数据时间	打开此开关后，您就可以指定读取数据的开始时间。
允许忽略部分算子状态	默认情况下，Flink系统会尝试将整个快照与正在提交的作业匹配。作业的修改引起算子状态的变化，会出现任务不能恢复的情况。此时您可以打开此开关，Flink系统将跳过无法匹配的状态，让作业正常启动起来。允许忽略部分算子状态详情请参见Allow None-Restored State。

在作业运维页面，查看作业运行状态。

作业的运行状态及含义详情如下表所示。


类别	状态	说明
过渡态	启动中	作业正在启动中，还没有完全启动。
稳定态	运行中	作业正在运行中。说明作业运行过程中，系统会对作业进行监测，根据监测结果对作业进行打分，用分数来表示作业的健康程度。如果作业的健康分不是100分，则代表作业有风险。此时，您可以单击健康分数，去查看具体的风险原因及修复建议，以使作业快速恢复正常。作业诊断功能详情请参见作业诊断。
	已停止	当您单击了停止后，作业显示为已停止。
	已完成	作业有限流。
错误态	已失败	作业运行失败。

进入目标批作业启动页面。
1. 登录实时计算控制台。
2. 在Flink全托管页签，单击对应工作空间操作列下的控制台。
3. 在左侧导航栏上，选择应用 > 作业运维。
4. 在作业模式下拉列表中，选择批作业。
在目标批作业名称右侧，单击操作列中的启动。

在作业启动配置-批模式对话框，填写资源信息。

资源信息填写说明如下表所示。


配置项	说明
JobManager CPU Cores	默认值为1。根据Flink最佳实践，单个JM内存资源需要至少配置为0.25 core和1 Gi，才能保证作业稳定运行。
JobManager Memory	最小值为1 Gi。单位建议使用Gi或Mi，例如，1024 Mi或1.5 Gi。
TaskManager CPU Cores	默认值为1。根据Flink最佳实践，单个TM内存资源需要至少配置为0.25 core和1 Gi，才能保证作业稳定运行。
TaskManager Memory	最小值为1 Gi。单位建议使用Gi或Mi，例如，1024 Mi或1.5 Gi。
自动推断并发度	开启后由系统自动设置并发度。说明批作业专用。
最大Slot个数	批作业可以使用的最大Slot数量，即最大能使用的资源。说明批作业专用。
Flink配置	可以配置的参数及说明，详情请参见Configuration。

作业启动后，您可以在作业运维页面，查看作业状态。

作业的运行状态及含义详情如下表所示。