Standalone集群模式是Flink自带的,此处仅供学习使用,真正的生产环境还是使用on yarn模式较多。

安装步骤如下:(以1.9.1版本为例)

1. 下载flink安装包,地址:https://flink.apache.org/downloads.html

2. 上传到linux服务器上后解压,并将flink-shaded-hadoop-2-uber-2.7.5-9.0.jar拷贝到flink解压包中的Lib目录下。

3. 修改conf目录下的配置文件flink-conf.yaml

配置主节点 (配置的时候centos-hadoop-node-01前一定要有一个空格,否则报错)

配置每个taskmanager的资源槽个数

2. 修改slaves文件:添加从节点(taskmanager运行的位置)

再将修改好的flink安装包拷贝到从节点

如:scp -r flink-1.9.0-standalone/ root@192.168.***.***:/usr/local/

 

3. 启动Flink集群

StandaloneSessionClusterEntrypoint对应JobManager

Logo

更多推荐