flink1.10.x 开启历史服务

修改 flink-conf.yaml

注意: 是 yaml 文件,:后面要有空格

flink-conf.yaml 有下面配置,但被注释了

配置如下:

# 配置task的存档目录
jobmanager.archive.fs.dir: hdfs://hadoop1:8020/flink/completed-jobs/

historyserver.web.address: hadoop1

# web页面端口
historyserver.web.port: 8082

# 配置historyserver目录
historyserver.archive.fs.dir: hdfs://hadoop1:8020/flink/completed-jobs/

下载 jar

flink 操作 HDFS,需要用到 flink-shaded-hadoop-3-uber-xxx.jar

访问 网址 下载下面的 jar 包:

flink-shaded-hadoop-3-uber-3.1.1.7.2.8.0-224-9.0.jar

拷贝到下面目录:

/program/flink-1.10.3/lib/

在 HDFS 创建目录

需要手动在 HDFS 上创建下面目录:

/flink/completed-jobs

命令

./historyserver.sh (start|start-foreground|stop)

开启

./historyserver.sh start

停止

./historyserver.sh stop

jps

执行 jps,看到下面进程:

125834 HistoryServer

表示启动成功

web页面查看

访问: http://hadoop1:8082


原文出处:/show_1IX1yYzCdB1D.html