You need to enable JavaScript to run this app.
导航
创建 Flink JAR 任务
最近更新时间:2024.04.01 15:26:07首次发布时间:2022.11.11 17:16:16

Flink 支持开发 JAR 类型任务。您可以自行编写业务应用程序并构建 JAR 包,只需上传应用 JAR 包并配置关键参数,便完成了 JAR 任务的开发,操作十分简单。

前提条件

您开发 JAR 任务前,应提前完成以下准备工作:

  • 项目负责人或项目管理员已经在项目内创建好 Flink 资源池,请参见创建通用-VCI 资源池
  • 项目开发人员(Project_Dev 角色)已提前将业务 JAR 包上传到资源库,请参见上传资源文件
  • 一般是由开发人员(Project_Dev)负责开发任务,请确保操作者已被添加为项目成员并为其关联角色,请参见添加项目成员

  1. 登录流式计算 Flink 版控制台

  2. 在顶部菜单栏选择目标地域。

  3. 在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。

  4. 在项目左侧导航栏选择任务开发 > Jupyter lab

  5. 任务开发页面单击加号按钮,创建任务。
    您也可以选择目标文件夹,直接在该文件夹中创建任务;也可以直接单击 Flink 任务下的 Flink Stream JAR

  6. 创建任务对话框,设置任务名称、所属文件夹、引擎版本等关键参数,然后单击确定
    图片

    配置

    说明

    任务名称

    自定义设置任务的名称。
    名称的字符长度限制在 1~48,支持数字、大小写英文字母、下划线(_)、短横线(-)和英文句号(.),且首尾只能是数字或字母。

    任务类型

    选择 Flink 任务 > Flink Stream > Jar

    所属文件夹

    从下拉列表中选择目标文件夹。
    系统默认存在一个数据开发文件夹,但为了更方便的管理任务,您可以自由创建文件夹。如何创建任务文件夹,请参见管理任务文件夹

    引擎版本

    目前支持 Flink 1.11-volcano 、Flink 1.16-volcano、Flink 1.17-volcano 版本,请按需选择。

    任务描述

    输入任务的描述语句,一般描述任务实现的功能。

  7. 在任务配置区域,设置任务关键参数。
    图片

    配置

    说明

    任务名称

    创建任务时设置的名称。

    Jar URI

    从下拉列表中选择已上传的 JAR 包资源。如果您还没有上传 JAR 包,请参见资源文件管理

    Entrypoint Class

    业务 JAR 包程序的主类,请根据界面提示填写。

    Entrypoint main args

    业务程序 main 函数的args[]参数,非必填项。请根据界面提示填写。

  8. 任务开发和配置完成后,单击保存

  1. 登录流式计算 Flink 版控制台

  2. 在顶部菜单栏选择目标地域。

  3. 在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。

  4. 在项目左侧导航栏选择任务开发 > Jupyter lab

  5. 任务开发页面单击加号按钮,创建任务。
    您也可以选择目标文件夹,直接在该文件夹中创建任务;也可以直接单击 Flink 任务下的 Flink Batch JAR

  6. 创建任务对话框,设置任务名称、所属文件夹、引擎版本等关键参数,然后单击确定
    图片

    配置

    说明

    任务名称

    自定义设置任务的名称。
    名称的字符长度限制在 1~48,支持数字、大小写英文字母、下划线(_)、短横线(-)和英文句号(.),且首尾只能是数字或字母。

    任务类型

    选择 Flink 任务 > Flink Batch > Jar

    所属文件夹

    从下拉列表中选择目标文件夹。
    系统默认存在一个数据开发文件夹,但为了更方便的管理任务,您可以自由创建文件夹。如何创建任务文件夹,请参见管理任务文件夹

    引擎版本

    目前支持 Flink 1.11-volcano 、Flink 1.16-volcano、Flink 1.17-volcano 版本,请按需选择。

    任务描述

    输入任务的描述语句,一般描述任务实现的功能。

  7. 在任务配置区域,设置任务关键参数。
    图片

    配置

    说明

    任务名称

    创建任务时设置的名称。

    Jar URI

    从下拉列表中选择已上传的 JAR 包资源。如果您还没有上传 JAR 包,请参见资源文件管理

    Entrypoint Class

    业务 JAR 包程序的主类,请根据界面提示填写。

    Entrypoint main args

    业务程序 main 函数的args[]参数,非必填项。请根据界面提示填写。

  8. 任务开发和配置完成后,单击保存