cd/opt/bigdata
tar xzvf flink-1.4.0-bin-hadoop28-scala_2.11.tgz
vi /etc/profile
添加:
export FLINK_HOME=/opt/bigdata/ flink-1.4.0
export PATH=$FLINK_HOME/bin:$PATH
source /etc/profile
vi flink-1.4.0/conf/flink-conf.yaml
修改:
jobmanager.rpc.address: cluster201
fs.hdfs.hadoopconf: $HADOOP_HOME/etc/hadoop
vi flink-1.4.0/conf/slaves
添加
cluster202
cluster203
主节点执行
./flink-1.4.0/bin/start-cluster.sh
重启
所有节点:
cd /opt/bigdata/zookeeper-3.4.10/bin
./zkServer.sh start
所有节点:
cd /opt/bigdata/kafka/bin
kafka-server-start.sh ../config/server.properties &
主节点:
cd /opt/bigdata/hadoop-2.8.3/sbin
./start-all.sh
主节点
cd /opt/bigdata/flink-1.4.0/bin
./start-cluster.sh