![Flink与Kylin深度实践](https://wfqqreader-1252317822.image.myqcloud.com/cover/467/37323467/b_37323467.jpg)
上QQ阅读APP看书,第一时间看更新
2.1 local模式部署安装
local模式下的Flink部署安装只需要使用单台机器,仅用本地线程来模拟其程序运行,不需要启动任何进程,适用于软件测试等情况。这种模式下,机器不用更改任何配置,只要安装JDK 8的运行环境即可。
1.上传安装包并解压
将编译之后的安装包上传到node01服务器的“/kkb/soft”路径下,然后进行解压。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_01.jpg?sign=1739595412-fKgXmon3YSyIvc6hvdc160Z1mJB6LEuF-0-45b7cac9ac69de2eb3fb1bd600bbd8cd)
2.直接使用脚本启动
解压安装包之后直接启动即可。执行以下命令。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_02.jpg?sign=1739595412-F5jno95PugRAU3VJWyTum2wTMOWKzAhz-0-c9d0427ee1b5d8907e7ca9fc1e1ee419)
启动成功之后,执行jps命令能查看最新启动的两个进程。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_03.jpg?sign=1739595412-P7XZnWvYBJvpefyaoBvmK6nE71hM8n8D-0-aca889c491e4ad6eec078a6e63a9d84c)
3.Web界面访问
成功启动两个进程之后,访问8081端口即可访问Flink的Web管理界面。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_04.jpg?sign=1739595412-nFhNU27TwO9YiJfYc7JfWDJ3XrpkZcH5-0-49ef5c4d21bc917b7b978942646cf938)
4.运行Flink自带的测试用例
在node01上使用Linux的nc命令向Socket发送一些单词。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_05.jpg?sign=1739595412-vQCH4tlgpDK6IxWHcD0Dx4pi22GNC3AX-0-1642f943ce4dc1c4c88a9e6749d48dc4)
在node01上启动Flink自带的单词统计程序,接收输入的Socket数据并进行统计。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/24_06.jpg?sign=1739595412-0VgVKwxaiI6MwXhWJLoA8bMGvS116Bxa-0-ae19f3d54ef7d6bd5defa23a5b8c8c2a)
5.查看统计结果
Flink自带的测试用例统计结果在log文件夹下面。
在node01上执行以下命令查看统计结果。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/25_01.jpg?sign=1739595412-32RIn6YKz3fpp4thaXds5OjoOT33Xlm2-0-65bfe814c1b3c76f1ae49f6b3d10161f)
关闭local模式。
![](https://epubservercos.yuewen.com/B89B1D/19773740901350206/epubprivate/OEBPS/Images/25_02.jpg?sign=1739595412-RzUIPkQG9R4UIVFPXEPCA6yBsyWXZqwk-0-f17ac4de8fed87f186b72d6f2b9b2bee)