本文为您介绍如何提交Flink半托管(基于ACK)作业至集群运行。

上传JAR包

  1. 登录实时计算统一控制台
  2. Flink半托管/ACK页签,单击对应工作空间操作列下的控制台
  3. 在左侧导航栏上,单击作业管理 > Jar包管理
  4. 在页面右上角,单击单击可添加文件上传JAR包。
    说明 系统支持上传最大为50 MB的JAR包。

创建作业

  1. 登录实时计算统一控制台
  2. Flink半托管/ACK页签,单击对应工作空间操作列下的控制台
  3. 在左侧导航栏上,单击作业管理 > 创建作业
  4. 标准页签,填写基本配置信息。创建作业
    参数解释如下表所示。
    配置项 说明
    作业名称 作业名称
    部署目标 Flink半托管(基于ACK)的部署目标,默认只有一个。
    Jar URI 选择您上传的JAR包,或者输入可以被公开读的JAR包URI,此URI需要符合HTTP协议。
    Entrypoint Class 程序的入口类
    说明 如果您的JAR未指定主类,请在此处输入您的Entrypoint Class类的标准路径。
    Entrypoint main args Main方法的参数
    并行度 作业并发数
    说明
    • 您可以根据实际业务需要,在高级页签,配置Flink配置资源日志等信息。
    • 您可以在YAML页签,直接修改配置信息。
  5. 单击创建

启动作业

  1. 登录实时计算统一控制台
  2. Flink半托管/ACK页签,单击对应工作空间操作列下的控制台
  3. 在左侧导航栏上,单击作业管理 > 作业列表
  4. 单击您创建的目标作业名称。
  5. 在作业详情页面,单击启动,即可将作业提交至集群运行。启动作业