Flink集群启动脚本(start-flin__k-cluster)
cd /usr/local/binsudo vi start-flink-cluster
脚本内容如下:
#!/bin/bashFLINK_HOME=/home/vagrant/modules/flink-1.10.0echo "start Flink-cluster-------------------------------------------------"for i in bigdata-node1dossh $i "source /etc/profile;${FLINK_HOME}/bin/start-cluster.sh"donesleep 10secho "start done..."echo "cluster jps status------------------------------------------------"jpsxexit 0
设置脚本执行权限:
sudo chmod +x start-flink-clustersudo chown vagrant:vagrant start-flink-cluster
Flink集群停止脚本(stop-flink-cluster)
cd /usr/local/binsudo vi stop-flink-cluster
脚本内容如下:
#!/bin/bashFLINK_HOME=/home/vagrant/modules/flink-1.10.0echo "stop Flink-cluster-------------------------------------------------"for i in bigdata-node1dossh $i "source /etc/profile;${FLINK_HOME}/bin/stop-cluster.sh"donesleep 10secho "stop done..."echo "cluster jps status------------------------------------------------"jpsxexit 0
设置脚本执行权限:
sudo chmod +x stop-flink-clustersudo chown vagrant:vagrant stop-flink-cluster
分发(选做):
# 使用root账户分发至其他节点sudo scp -r /usr/local/bin/*-flink-cluster root@bigdata-node2:/usr/local/bin/sudo scp -r /usr/local/bin/*-flink-cluster root@bigdata-node3:/usr/local/bin/
