安装flink以及flink启动异常:start-cluster.sh

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.0export PATH=$PATH:$FLINK_HOME/bin

3.根据本机的资源(CPU、内存大小)修改flink-1.11.0/conf/flink-conf.yaml

image.png

image.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,成功

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容