开发和生产环境隔离,当任务开发人员完成开发和调试后,可以将任务上线到生产环境。
提前创建好 Flink 资源池,请参见创建通用-VCI 资源池。
Flink Batch 任务不支持 GANG 调度策略,仅支持 DRF 调度策略。
在顶部菜单栏选择目标地域。
在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。
在项目左侧导航栏选择任务开发 > Jupyter lab。
在任务开发页面下查找并单击目标任务,然后在编辑区上方选择正确的执行方式和引擎版本,再单击上线。
说明
Flink Stream 类型任务选择执行方式为 STREAMING;Flink Batch 类型任务选择执行方式为 BATCH。
在任务上线设置对话框,选择运行资源池、设置任务优先级和调度策略,然后单击确定。
执行任务上线操作后,系统会提示任务上线成功,可以前往任务管理页面查看;任务上线后,将展示在任务列表第一个。
配置 | 说明 |
---|---|
运行资源池 | 从下拉列表中选择任务运行的 Flink 资源池。 注意 如果您提交的任务开启了自动调优,则必须运行在按量付费类型的资源池。 |
任务优先级 | 系统默认预置的优先级为 L3,您可以按需设置任务优先级,数字越小优先级越高。 |
调度策略 | 根据需求配置任务调度策略:
|
调度时长 | 设置为 GANG 调度策略时,需要设置调度时长。调度时长表示再次调度的时间间隔,即任务拉起不成功会再次重试调度。 |
更多配置 | SQL 任务支持在上线前跳过深度检查,允许任务强制上线。 |
任务上线后,您可以在任务管理页面进行任务启动、停止、下线、查看 Flink UI、查看任务资源消耗等操作。
具体操作,请参见作业基础操作。