CentOS7-Flink

Flink集群启动脚本（start-flink-cluster）

cd /usr/local/bin
sudo vi start-flink-cluster

脚本内容如下：

#!/bin/bash
FLINK_HOME=/home/bigdata/modules/flink-1.10.0
echo "start Flink-cluster-------------------------------------------------"
for i in LTSR005
do 
ssh $i "source /etc/profile;${FLINK_HOME}/bin/start-cluster.sh"
done
sleep 10s
echo "start done..."
echo "cluster jps status------------------------------------------------"
jpsx
exit 0

设置脚本执行权限：

sudo chmod +x start-flink-cluster
sudo chown bigdata:bigdata start-flink-cluster

Flink集群停止脚本（stop-flink-cluster）

cd /usr/local/bin
sudo vi stop-flink-cluster

脚本内容如下：

#!/bin/bash
FLINK_HOME=/home/bigdata/modules/flink-1.10.0
echo "stop Flink-cluster-------------------------------------------------"
for i in LTSR005
do 
ssh $i "source /etc/profile;${FLINK_HOME}/bin/stop-cluster.sh"
done
sleep 10s
echo "stop done..."
echo "cluster jps status------------------------------------------------"
jpsx
exit 0

设置脚本执行权限：

sudo chmod +x stop-flink-cluster
sudo chown bigdata:bigdata stop-flink-cluster

分发（选做）：

# 使用root账户分发至其他节点
sudo scp -r /usr/local/bin/*-flink-cluster root@LTSR006:/usr/local/bin/
sudo scp -r /usr/local/bin/*-flink-cluster root@LTSR007:/usr/local/bin/
sudo scp -r /usr/local/bin/*-flink-cluster root@LTSR003:/usr/local/bin/
sudo scp -r /usr/local/bin/*-flink-cluster root@LTSR008:/usr/local/bin/