0750-7.0.3-如何在CDP DC7.0.3集群部署Flink1.9.1

文件写作目的

在上一篇文章中，费森介绍了“如何获得Cloudera的Flink包裹包”和“0733-7.0.3-如何在Redhat7.6中安装CDP DC7.0.3”。基于以前的集群环境，Fayson在本文中主要介绍了如何使用Packet在CDP DC7.0.3集群中安装Flink1.9.1。

文档概述

1。如何安装FLink1.9.1

2。运行Flink示例来验证

测试环境

1。操作系统红帽7.2

2。CDP DC 7.0.3

3。使用root操作

安装Flink

1。为Flink1.9.1准备csd文件，并将其放在cloudera管理器服务器的/opt/cloudera/csd目录中。然后重新启动云管理器服务器服务

2。下载Flink1.9.1包并将其部署到/var/www/html/Flink1.9.1目录下的httpd服务

3。重启完成后，可以在添加服务页面上看到链接服务

4。登录CM，点击左侧菜单栏中的“宗地”按钮，进入宗地管理界面配置

。进入宗地管理界面后，点击“宗地库&当“网络设置”菜单配置Flink的本地宗地库

时，点击“保存并验证配置”，关闭配置界面，分别查看Flink信息

进行“下载、分发和激活”操作。完成后，将显示以下信息:

5。进入客户经理主页，点击“添加服务”

6。选择添加Flink服务，然后单击继续

7。选择Flink历史服务器和网关节点。单击继续

8。单击继续

9。等待Flink历史服务器成功启动，单击继续

10。安装完成。单击“完成”返回到CM主页

。发现Flink状态为灰色，CMS有重启提示，根据提示重启CMS服务，重启过程轻微重新启动后，Flink服务正常。

Flink样本运行

1。执行flink自己的例子中的字数统计例子

Hadoop fs-mkdir-p word count/input Hadoop fs-mkdir-p word count/output Hadoop fs-put dfclear word count/input FLINK run-m tweet-cluster-yn 3-yjm 1024-YTM 1024/opt/cloudera/parcels/FLINK/lib/FLINK/examples/streaming/WordCount . jar-input HDFS:///user/Root/word count/input/dfclear-output DFS:///user/Root/word count/output | 156查看输出结果

3。这一任务可以分别在纱和弗林克的界面上看到

摘要

1。基于宗地在CDPD安装Flink1.9.1与在CDH5和CDH6集群下安装Kafka、Spark和其他服务是一致的

2。对于CDP DC中未包括的服务，有必要将csd添加到CM节点的/opt/cloudera/csd目录中，并重新启动cloudera-SCM-服务器服务。

3。弗林克依靠纱线、HDFS和动物园管理员服务来运行，所以至少要确保这些服务安装在CDP DC集群中。

本文由 在线网速测试 整理编辑，转载请注明出处，原文链接：https://www.wangsu123.cn/news/644.html。