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