MAPREDUCE服务 MRS-配置并导入样例工程:参考信息
参考信息
Flink客户端lib目录、opt目录中都有flink jar包,其中lib目录中默认是flink核心jar包,opt目录中是对接外部组件的jar包(例如flink-connector-kafka*.jar),若应用开发中需要请手动拷贝相关jar包到lib目录中。
针对Flink提供的几个样例工程,其对应的运行依赖包如下:
样例工程 |
依赖包 |
说明 |
---|---|---|
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 |
- |