以下操作均在主节点进行
1.环境变量
添加FLINK_HOME以及path的内容：
1export FLINK_HOME=/bigdata/flink-1.6.1 2 3export PATH=$PATH:$JAVA_HOME/bin:$ZOOKEEPER_HOME/bin:$KAFKA_HOME/bin:${FLINK_HOME}/bin
2.修改conf/flink-conf.yaml
这几乎是最简单的配置方式了，主要注意要修改jobmanager.rpc.address为集群中jobManager的IP或hostname。检查点以及HA的参数都没有配置。
jobmanager.rpc.address: master
3.修改slaves文件
这个文件中存放的信息是taskmanager的hostname。
4.复制flink目录到集群中其他的机器
1[root@master ~]# scp -r /bigdata/flink-1.6.1/ root@192.168.36.27:/bigdata/ 2[root@master ~]# scp -r /bigdata/flink-1.6.1/ root@192.168.36.28:/bigdata/
5.启动Flink集群
先启动zookeeper、kafka、HDfS。
启动Flink：[root@master ~]# start-cluster.sh
master：
1[root@master ~]# jps 2961 Kafka 322306 QuorumPeerMain 416786 ResourceManager 5858 StandaloneSessionClusterEntrypoint 615996 SecondaryNameNode 71404 TaskManagerRunner 813853 NameNode 932701 DataNode 10431 Jps
worker1:
1[root@worker1 ~]# jps 232372 StandaloneSessionClusterEntrypoint 325285 Kafka 419046 QuorumPeerMain 516726 Jps 68137 NodeManager 75660 DataNode 8351 TaskManagerRunner
worker2:
1[root@worker2 ~]# jps 214592 TaskManagerRunner 37602 NodeManager 418388 QuorumPeerMain 54984 DataNode 614139 StandaloneSessionClusterEntrypoint 716060 Jps 823422 Kafka
关闭Flink：[root@master ~]# stop-cluster.sh