实时计算Flink版：作业启动

前提条件

其他阿里云账号或RAM用户共同使用实时计算Flink版产品时，需要为阿里云账号或RAM用户授权，以进行作业启动等相关操作，详情请参见阿里云账号角色授权、RAM授权和作业操作授权。

使用限制

• 仅流作业支持填写启动选项。

• 仅实时计算引擎VVR4.0.11及以上版本支持State兼容性检测。

• 仅日志服务SLS和消息队列Kafka支持在界面上设置源表开始时间。

  作业启动界面指定的读取数据时间优先级高于作业DDL代码里设置的startTime。即如果您在作业DDL和作业启动界面都指定了读取数据时间，则作业启动界面指定的读取数据时间生效。

  说明

  • 不是所有的Connector都支持startTime，详情请参见各Connector WITH参数是否包含startTime，例如日志服务SLS WITH参数。

  • 只有全新启动作业并指定了startTime，startTime才生效。如果基于Checkpoint或Savepoint启动作业，即使指定了startTime，startTime也不会生效。

注意事项

在启动作业时，如果您选择从最新状态或指定状态启动作业时，系统会进行State兼容性检测。兼容性检测详情请参见Flink State兼容性参考。

操作步骤

1. 进入作业启动界面。

   1. 登录实时计算控制台。

   2. 在Flink全托管页签，单击对应工作空间操作列下的控制台。

   3. 在作业运维页面的下拉列表中，选择流作业或批作业。

      

2. 在目标作业名称右侧，单击操作列下的启动。

3. （可选）流作业需要填写启动选项信息。

   • 无状态启动

     当您是新上线作业或者无法复用State时，需要选择无状态启动。此外，您需要根据业务情况决定是否打开自动调优。

     策略	说明
     指定源表开始时间	选中指定源表开始时间并指定具体的时间信息。
     配置自动调优	打开该开关后，您需要选择调优模式： 智能调优：系统将在资源使用率比较低时，自动降低资源配置，在资源使用率提高到一定阈值时，再自动提高资源配置。详情请参见开启并配置智能调优。 定时调优：选择定时调优后，您需要在下拉列表中选择定时计划。一个计划中可以包含多组资源和时间点的对应关系。您可以根据各时间段的资源使用情况，配置对应的资源。详情请参见开启并配置定时调优。

   • 有状态启动

     您可以根据业务情况选择具体的启动策略，以及决定是否打开自动调优。

     策略	说明
     从最新状态恢复	从快照或者系统检查点的最新状态进行恢复。如果您选择从最新状态启动作业时，系统会进行State兼容性检测。兼容性检测详情请参见Flink State兼容性参考。
     从指定状态恢复	选择指定的快照，快照创建步骤详情请参见作业状态集管理。
     从其他作业恢复	选择从其他作业恢复后，您需要指定目标作业及对应的快照，来进行作业恢复。支持作业间快照的共享，但需要满足作业间的状态的兼容性，详情请参见作业状态集管理。
     允许忽略部分算子状态（AllowNonRestoredState） 说明 仅JAR作业支持。	默认情况下，Flink系统会尝试将整个快照与正在提交的作业匹配。作业的修改引起算子状态的变化，会出现任务不能恢复的情况。此时您可以打开此开关，Flink系统将跳过无法匹配的状态，让作业先正常启动起来。允许忽略部分算子状态详情请参见Allow None-Restored State。
     配置自动调优	打开该开关后，您需要选择调优模式： 智能调优：系统将在资源使用率比较低时，自动降低资源配置，在资源使用率提高到一定阈值时，再自动提高资源配置。详情请参见开启并配置智能调优。 定时调优：选择定时调优后，您需要在下拉列表中选择定时计划。一个计划中可以包含多组资源和时间点的对应关系。您可以根据各时间段的资源使用情况，配置对应的资源。详情请参见开启并配置定时调优。

4. 单击启动。

   在作业运维页面，查看作业运行状态，详情请参见查看作业运行状态。