
上QQ阅读APP看书,第一时间看更新
2.2 standalone模式部署安装
使用standalone模式需要启动Flink的主节点JobManager以及从节点TaskManager,具体的任务进程划分见表2-1。
表2-1 Flink任务进程划分

1.更改配置文件
停止node01服务器local模式下的两个进程后,修改其配置文件。
在node01服务器上执行以下命令更改Flink配置文件。

指定Jobmanager所在的服务器为node01。

在node01上执行以下命令更改slaves配置文件。

2.分发安装包
将node01服务器的Flink安装包分发到其他机器上面去。执行以下命令。

3.启动Flink集群
在node01上执行以下命令启动Flink集群。

4.访问页面
访问以下页面。

5.运行Flink自带的测试用例
在node01上执行以下命令启动Socket服务,输入单词。

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

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