web控制页面介绍
1、当前集群的状态，3个task，0个运行的。
2、运行的Job和完成的Job都是0个。
3、当前TaskManager的情况，我们的集群是三个TaskManager。
4、JobManager的基本信息
5、提交Job
打包
6、将poml文件中的主程序删除，修改StreamWordCount的host和端口号，为app-11和7777
7、查看Java版本
命令：java -version
8、压缩程序
命令：tar -zcf Flink.tar Flink/
9、拷贝到app-11上
命令：scp Flink.tar 192.168.60.139:/workspace_logs/
10、返回app-11，将程序拷贝到Flink安装目录下
命令：cp /workspace_logs/Flink.tar /hadoop/Flink/
11、解压程序
命令：tar -xf Flink.tar
12、进入到这个程序的目录下
命令：cd Flink
13、程序打包
命令：
mvn clean scala:compile compile package
14、查看打包程序
命令：ls target/
15、将打包好的程序拷贝到Flink安装目录下
命令：cp target/FlinkTutorial-1.0-SNAPSHOT-jar-with-dependencies.jar /hadoop/Flink/
提交job
16、返回网页，上传job，找到Workspace目录下的jar包上传
17、在new terminal中启动7777端口号
命令：nc -lk 7777
18、填写主程序和相关的配置信息
19、在Running Jobs中可以查看到信息
20、在7777端口号下输入Hello Word
21、在Task Manager中的studout中可以看到输出结果
详细学习内容可观看Spark快速大数据处理扫一扫~~~或者引擎搜索Spark余海峰
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
