MAPREDUCE服务 MRS-配置FlinkServer作业中添加第三方依赖jar:上传依赖包
上传依赖包
- 登录 FusionInsight Manager,访问Flink WebUI,请参考访问FlinkServer WebUI界面。
- 单击“依赖管理”进入依赖管理页面。
- 单击“添加依赖”,可参考如下添加依赖。
表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
描述信息
添加的依赖的描述信息。
-
- 单击“确定”。
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- MapReduce服务_什么是Flink_如何使用Flink
- 提高软件交付效率与质量方式_软件发布_制品仓库工具-华为云
- 使用SpringBoot构建HTTP函数_functiongraph_函数工作流
- 数据转发至函数工作流_数据处理_FunctionGraph处理流数据
- 制品仓库是什么_制品仓库有什么能力_软件发布-华为云
- 函数工作流自动更新ECS证书_ECS证书自动更新_弹性云服务器
- MapReduce服务_什么是Hive_如何使用Hive
- 大数据分析是什么_使用MapReduce_创建MRS服务
- 什么是函数工作流_functiongraph是什么_函数工作流服务