Flink与Kylin深度实践
上QQ阅读APP看书,第一时间看更新

2.1 local模式部署安装

local模式下的Flink部署安装只需要使用单台机器,仅用本地线程来模拟其程序运行,不需要启动任何进程,适用于软件测试等情况。这种模式下,机器不用更改任何配置,只要安装JDK 8的运行环境即可。

1.上传安装包并解压

将编译之后的安装包上传到node01服务器的“/kkb/soft”路径下,然后进行解压。

2.直接使用脚本启动

解压安装包之后直接启动即可。执行以下命令。

启动成功之后,执行jps命令能查看最新启动的两个进程。

3.Web界面访问

成功启动两个进程之后,访问8081端口即可访问Flink的Web管理界面。

4.运行Flink自带的测试用例

在node01上使用Linux的nc命令向Socket发送一些单词。

在node01上启动Flink自带的单词统计程序,接收输入的Socket数据并进行统计。

5.查看统计结果

Flink自带的测试用例统计结果在log文件夹下面。

在node01上执行以下命令查看统计结果。

关闭local模式。