1、解压缩:
gzip -dv flink-1.10.0-bin-scala_2.12.tgz
tar -xvf flink-1.10.0-bin-scala_2.12.tar -C /home
2、配置:
修改配置文件flink-conf.yaml:
jobmanager.rpc.address: bigdata-1
jobmanager.heap.size: 4096m
taskmanager.memory.process.size: 4096m
taskmanager.numberOfTaskSlots: 6
修改配置文件masters
bigdata-1:8081
修改配置文件slaves
bigdata-1
bigdata-2
bigdata-3
bigdata-4
bigdata-5
3、分发到其它服务器:
scp -r flink-1.10.0/ bigdata-2:/home
scp -r flink-1.10.0/ bigdata-3:/home
scp -r flink-1.10.0/ bigdata-4:/home
scp -r flink-1.10.0/ bigdata-5:/home
4、启停:
./start-cluster.sh
./stop-cluster.sh
