一、创建flink源 1，安装 httpd 服务（随便一台服务器，这里选node01） [root@node01~]# yum -y install httpd

[root@node01~]# service httpd restart

[root@node01 ~]# chkconfig httpd on 安装完成后，会生成 /var/www/html目录（相当于Tomcat的webapps目录）

2、下载下边两个包，并放到 /var/www/html/flink目录 (需要在 /var/www/html先建 flink目录)

[root@node01~]# wget https://·/1a42ad98dee14cf7a8836b5652d8dddc.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAcm9va2llX2JpZ2RhdGE=,size_20,color_FFFFFF,t_70,g_se,x_16)

4.下一步，部署，完成。

5.在yarn 运行界面可以看到多了一个应用，通过后边的?ApplicationMaster?

可以跳到 flink 管理界面

六、跑一个作业进行测试(在Flink Master所在的服务器 node03)

1，在ambari flink 配置界面加上下边的参数，classloader.check-leaked-classloader: false

并保存。

2，设置Hadoop_ClassPath

[root@node03~]# export HADOOP_CLASSPATH=`hadoop classpath`

3，执行测试程序（node03）

[root@node03~]# /opt/flink/bin/flink run -m yarn-cluster -yjm 1024 -ytm 1024 /opt/flink/examples/batch/WordCount.jar

4、可以在yarn看到多了一个flink作业在运行

5、完成

---

1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，会注明原创字样,如未注明都非原创，如有侵权请联系删除！；3.作者投稿可能会经我们编辑修改或补充；4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。