下面将介绍Flink原生任务的托管操作。
新建任务-托管任务。
支持托管jar包,需要先上传jar包,详见项目管理->资源文件管理。
准备好jar包后,输入关键字搜索已上传文件。
基础信息 :任务名称、描述、责任、队列,优先级别。
获取推荐配置:根据任务的历史24小时运行情况,给出推荐配置。
Flink 运行参数:Flink 相关的动态参数和执行参数,具体设置详见 Flink官网文档。
用户自定义参数:kv格式,按需设置。
任务测试通过后,先“保存”任务生成一个草稿版本。然后点击”提交上线“,即按最新的版本启动一个 Flink 实例。任务运维可在“实时任务运维”中操作。
若在运维列表的“重启”任务,默认按线上配置重启,而非最新版本草稿。
每次上线会生成一个版本,在“历史版本”功能中可以查看、对比和回滚,回滚的效果是恢复至草稿,需要重新点击上线。