目录
解压到安装目录并重命名为flink
配置环境变量
修改masters,slaves,flink-conf.yaml
进入conf目录
编辑slaves文件
编辑flink-conf.yaml文件
拷贝到另外两台机器
启动flink
输入jps查看
解压到安装目录并重命名为flinktar zxvf /h3cu/flink-1.10.2-bin-scala_2.11.tgz -C /usr/local/src
mv /usr/local/src/flink-1.10.2 /usr/local/src/flink配置环境变量
vim /root/.bash_profile
export Flink_HOME=/usr/local/src/flink PATH=$Flink_HOME/bin:$PATH修改masters,slaves,flink-conf.yaml 进入conf目录
cd /usr/local/src/flink/conf编辑masters文件
vim masters
#删除默认的改为 slave:8082编辑slaves文件
vim slaves
#删除默认的改为 slave slave1 slave2编辑flink-conf.yaml文件
vim flink-conf.yaml
#改为主机名 jobmanager.rpc.address: slave #改为3,因为三台机器的集群 parallelism.default: 3 #取消注释,改为8082 rest.port: 8082拷贝到另外两台机器
scp -r /usr/local/src/flink-1.10.2/ slave1:/usr/local/src/
scp -r /usr/local/src/flink-1.10.2/ slave2:/usr/local/src/启动flink
/usr/local/src/flink-1.10.2/bin/start-cluster.sh输入jps查看
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)