Flink-Standalone模式的配置及启动测试与查看

安装解压

下载地址 : https://flink.apache.org/downloads.html
这边注意得是:如果下以前得版本(https://archive.apache.org/dist/flink/flink-1.7.1/) 会发现
其中 flink-1.7.1-bin-scala_2.11.tgz 这种为纯净得版本,那种带hadoop27分别对应得是hadoop版本

Flink-Standalone模式的配置及启动测试与查看

如果下了纯净版本 flink-1.7.1-bin-scala_2.12.tgz 还需要下载与之对应得hadoop版本得jar包才能去做yarn提交,但是如果知识standalone模式可以不用导入这个jar,用纯净版得就行了,使用得话将这个jar包放到flink目录下得lib目录下

Flink-Standalone模式的配置及启动测试与查看
这边我使用的是flink-1.10.0-bin-scala_2.11.tgz,然后也下载了一下hadoop得jar包为后面得yarn模式先准备着

Flink-Standalone模式的配置及启动测试与查看

配置slaves文件

修改 /conf/slaves文件Flink-Standalone模式的配置及启动测试与查看

配置flink-conf.yaml文件,然后分发给其他集群

修改 flink/conf/flink-conf.yaml 文件

Flink-Standalone模式的配置及启动测试与查看

启动

Flink-Standalone模式的配置及启动测试与查看

查看页面

访问http://hadoop102:8081可以对flink集群和任务进行监控管理。

Flink-Standalone模式的配置及启动测试与查看