上传
将 flink-1.10.3-bin-scala_2.12.tgz 上传到linux的 /program 目录
解压缩
root 用户执行下面命令:
tar zxvf flink-1.10.3-bin-scala_2.12.tgz --no-same-owner
修改 conf/flink-conf.yaml
注意: 是 yaml 文件,:后面要有空格
vim conf/flink-conf.yaml
找到下面配置:
jobmanager.rpc.address: localhost
修改如下:
jobmanager.rpc.address: hadoop1
修改 conf/masters
将内容修改如下:
hadoop1:8081
修改 conf/slaves
内容清空,添加下面内容:
hadoop2
hadoop3
分发
分发给 hadoop2:
rsync -av /program/flink-1.10.3 root@hadoop2:/program
分发给 hadoop3:
rsync -av /program/flink-1.10.3 root@hadoop3:/program
查看
登录 hadoop2、hadoop3,查看文件是否以同步
启动集群
进入 /program/flink-1.10.3/bin 目录:
cd /program/flink-1.10.3/bin
执行下面命令:
./start-cluster.sh
执行结果如下:
Starting cluster.
Starting standalonesession daemon on host hadoop1.
Starting taskexecutor daemon on host hadoop2.
Starting taskexecutor daemon on host hadoop3.
查看是否启动
hadoop1
登录 hadoop1 执行下面命令:
jps
看到下面进程说明启动成功:
114358 StandaloneSessionClusterEntrypoint
hadoop2
登录 hadoop2 执行下面命令:
jps
看到下面进程说明启动 jobmanager.sh 成功:
118642 TaskManagerRunner