流式计算 Flink版
流式计算 Flink版
- 文档首页
流式计算 Flink版用户指南任务开发作业开发开发 Flink 任务创建 Flink 任务创建 Flink JAR 任务
文档反馈
问问助手Flink 支持开发 JAR 类型任务。您可以自行编写业务应用程序并构建 JAR 包，只需上传应用 JAR 包并配置关键参数，便完成了 JAR 任务的开发，操作十分简单。
前提条件
您开发 JAR 任务前，应提前完成以下准备工作：
- 项目负责人或项目管理员已经在项目内创建好 Flink 资源池，请参见创建通用-VCI 资源池。
- 项目开发人员（Project_Dev 角色）已提前将业务 JAR 包上传到资源库，请参见上传资源文件。
- 一般是由开发人员（Project_Dev）负责开发任务，请确保操作者已被添加为项目成员并为其关联角色，请参见添加项目成员。
开发 Flink JAR 流式任务
- 登录流式计算 Flink 版控制台。
- 在顶部菜单栏选择目标地域。
- 在左侧导航栏选择项目管理，在搜索框中根据项目名称进行模糊搜索，然后单击项目区块进入项目。
- 在项目左侧导航栏选择作业开发。
- 在作业开发页面单击加号按钮，创建任务。
您也可以选择目标文件夹，直接在该文件夹中创建任务；也可以直接单击 Flink 任务下的 Flink JAR。 - 在创建作业对话框，设置任务名称、所属文件夹、引擎版本等关键参数，然后单击确定。
配置 | 说明 |
|---|---|
任务名称 | 自定义设置任务的名称。 |
作业类型 | 选择 Flink 任务 > Flink JAR。 |
所属文件夹 | 从下拉列表中选择目标文件夹。 |
引擎版本 | 目前支持 Flink 1.11-volcano 、Flink 1.16-volcano、Flink 1.17-volcano 版本，请按需选择。 |
任务描述 | 输入任务的描述语句，一般描述任务实现的功能。 |
- 在任务配置区域，设置任务关键参数。
配置 | 说明 |
|---|---|
任务名称 | 创建任务时设置的名称。 |
Jar URI | 从下拉列表中选择已上传的 JAR 包资源。如果您还没有上传 JAR 包，请参见资源文件管理。 |
Entrypoint Class | 业务 JAR 包程序的主类，请根据界面提示填写。 |
Entrypoint main args | 业务程序 main 函数的 |
- 任务开发和配置完成后，单击保存。
开发 Flink Batch JAR 任务
- 登录流式计算 Flink 版控制台。
- 在顶部菜单栏选择目标地域。
- 在左侧导航栏选择项目管理，在搜索框中根据项目名称进行模糊搜索，然后单击项目区块进入项目。
- 在项目左侧导航栏选择任务开发 > Jupyter lab。
- 在任务开发页面单击加号按钮，创建任务。
您也可以选择目标文件夹，直接在该文件夹中创建任务；也可以直接单击 Flink 任务下的 Flink Batch JAR。 - 在创建任务对话框，设置任务名称、所属文件夹、引擎版本等关键参数，然后单击确定。
配置 | 说明 |
|---|---|
任务名称 | 自定义设置任务的名称。 |
任务类型 | 选择 Flink 任务 > Flink Batch > Jar。 |
所属文件夹 | 从下拉列表中选择目标文件夹。 |
引擎版本 | 目前支持 Flink 1.11-volcano 、Flink 1.16-volcano、Flink 1.17-volcano 版本，请按需选择。 |
任务描述 | 输入任务的描述语句，一般描述任务实现的功能。 |
- 在任务配置区域，设置任务关键参数。
配置 | 说明 |
|---|---|
任务名称 | 创建任务时设置的名称。 |
Jar URI | 从下拉列表中选择已上传的 JAR 包资源。如果您还没有上传 JAR 包，请参见资源文件管理。 |
Entrypoint Class | 业务 JAR 包程序的主类，请根据界面提示填写。 |
Entrypoint main args | 业务程序 main 函数的 |
- 任务开发和配置完成后，单击保存。