MAPREDUCE服务 MRS-配置FlinkServer作业中添加第三方依赖jar:上传依赖包

时间:2024-08-01 19:24:15

上传依赖包

  1. 登录 FusionInsight Manager,访问Flink WebUI,请参考访问FlinkServer WebUI界面
  2. 单击“依赖管理”进入依赖管理页面。
  3. 单击“添加依赖”,可参考如下添加依赖。

    表1 添加依赖

    参数

    描述

    示例

    是否自定义connector

    是否自定义connector,根据实际需求选择:

    • 是:文件为自定义connector依赖包。
    • 否:文件为非自定义connector依赖包。

    名称

    添加的依赖名称,需与上传的依赖包中connector的连接名一致。不支持上传同名依赖包。

    kafka

    注册jar

    jar包的上传方式:

    • 上传文件:添加本地的jar包
    • 指定路径:已准备好的依赖文件的HDFS路径

    上传文件

    上传文件

    注册jar选择为“上传文件”时,需通过该项上传本地jar文件。

    -

    指定路径

    注册jar选择为“指定路径”时,需通过该项输入依赖文件的HDFS路径(需提前准备好jar包上传至HDFS)。

    /flink_upload_test/flink-connector-kafka-customization.jar

    描述信息

    添加的依赖的描述信息。

    -

  4. 单击“确定”。
support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_249181.html