简介:
本博客基于1.13.6版本Flink,实现批处理提交到yarn执行,并实现读取HDFS上文件实现批处理,有完整的Flink代码,已完成编译,开箱简单修改即可用,避免了大家编程、编译、提交yarn上的一些错误。
本工程提供
1、项目源码及详细注释,简单修改即可用在实际生产代码
2、成功编译截图
3、linux提交命令
4、提交到yarn上截图
5、自己编译过程中可能出现的问题
6、执行结果
成功编译成功信息如下
[INFO] --- maven-surefire-plugin:2.12.4:test (default-test) @ flink-batch ---
[INFO] No tests to run.
[INFO]
[INFO] --- maven-jar-plugin:2.4:jar (default-jar) @ flink-batch ---
[INFO] Building jar: D:\flink\flink-batch\target\flink-batch-1.0-SNAPSHOT.jar
[INFO]
[INFO] --- maven-assembly-plugin:3.0.0:single (make-assembly) @ flink-batch ---
[INFO] Building jar: D:\flink\flink-batch\target\flink-batch-1.0-SNAPSHOT-jar-with-dependencies.jar
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ----