MAPREDUCE服务 MRS-配置并导入样例工程:参考信息

时间:2024-05-11 16:36:28

参考信息

Flink客户端lib目录、opt目录中都有flink jar包,其中lib目录中默认是flink核心jar包,opt目录中是对接外部组件的jar包(例如flink-connector-kafka*.jar),若应用开发中需要请手动拷贝相关jar包到lib目录中。

针对Flink提供的几个样例工程,其对应的运行依赖包如下:

表1 样例工程依赖包

样例工程

依赖包

说明

DataStream程序样例工程(Java/Scala)

flink-dist_*.jar

在Flink的客户端或者服务端安装路径的lib目录下获取。

异步Checkpoint机制程序样例工程(Java/Scala)

向Kafka生产并消费数据程序样例工程(Java/Scala)

kafka-clients-*.jar

由Kafka组件发布提供,可在Kafka组件客户端或者服务端安装路径下的lib目录下获取。

flink-connector-kafka_*.jar

在Flink客户端或者服务端安装路径的opt目录下获取。

pipeline程序样例工程(Java/Scala)

flink-dist_*.jar

在Flink的客户端或者服务端安装路径的lib目录下获取。

flink-connector-netty_*.jar

在二次开发样例代码编译后产生的lib文件夹下获取。

curator-client-2.12.0.jar

curator-framework-2.12.0.jar

Stream SQL Join样例工程(Java)

flink-dist_2.11*.jar

在Flink的客户端或者服务端安装路径的lib目录下获取。

kafka-clients-*.jar

由Kafka组件发布提供,可在Kafka组件客户端或者服务端安装路径下的lib目录下获取。

flink-connector-kafka_2.11*.jar

在Flink客户端或者服务端安装路径的opt目录下获取。

flink-table_2.11*.jar

-

support.huaweicloud.com/devg3-mrs/mrs_07_050008.html