修改 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
表示启动成功