1、准备git仓库和项目代码
我的项目地址
https://gitee.com/chenwejob/flink-streamx-demo.git
代码功能:
是监控 hadoop01 9999端口的数据 按照 空格差分做单词计数
2、配置project
image.png
image.png
3、配置applicatiom
image.png
4、运行步骤
先构建project
再构建application
再发布app到yarn集群
image.png
5、 测试功能
成功.png