本文为您介绍如何提交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. 在作业详情页面，单击启动，即可将作业提交至集群运行。启动作业