1.安装flink
下载压缩包wget https://archive.apache.org/dist/flink/flink-1.11.0/flink-1.11.0-bin-scala_2.11.tgz
等待下载。
下载完成后,解压缩:tar -xzf flink-1.11.0-bin-scala_2.11.tgz
2.配置环境变量
输入export FLINK_HOME=/usr/local/flink-1.11.0
和export PATH=$PATH:$FLINK_HOME/bin
3.根据本机的资源(CPU、内存大小)修改flink-1.11.0/conf/flink-conf.yaml
image.pngimage.png
taskmanager.numberOfTaskSlots: 120
jobmanager.memory.process.size: 4096m
taskmanager.memory.process.size: 4096m
4.测试start
image.png如上图所示,共使用4种方式进行start测试,只有第四种方式启动成功,前三种flink启动异常。
- 第一种,输入
start-cluster.sh
,失败 - 第二种,进入start-cluster.sh文件所在路径后输入
start-cluster.sh
,失败 - 第三种,在start-cluster.sh文件所在路径输入
sh start-cluster.sh
,失败 - 第四种,输入
./start-cluster.sh
,启动flink集群成功
5.测试stop
image.png如上图所示,输入
./stop-cluster.sh
,成功
网友评论