flink1.10.x standalone模式-安装部署

上传

将 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

原文出处:/show_1IX1yZ5V4q1J.html