flink启动HistoryServer服务
mrs 3.1.0集群启动flink HistoryServer服务
1.修改$FLINK_HOME/conf/flink-conf.yaml文件
#==============================================================================
# HistoryServer
#==============================================================================
# 指定由JobManager归档的作业信息所存放的目录,这里使用的是HDFS
jobmanager.archive.fs.dir: hdfs:///flink/completed-jobs/
# History Server所绑定的ip
historyserver.web.address: xxxx
# 指定History Server所监听的端口号(默认8082)
historyserver.web.port: 8082
# 指定History Server扫描哪些归档目录,多个目录使用逗号分隔
historyserver.archive.fs.dir: hdfs:///flink/completed-jobs/
# 指定History Server间隔多少毫秒扫描一次归档目录
historyserver.archive.fs.refresh-interval: 10000
#查找到的归档文件会下载并缓存到本地存储路径,默认/tmp目录下面,默认路径为System.getProperty("java.io.tmpdir") + File.separator + "flink-web-history-" + UUID.randomUUID()
historyserver.web.tmpdir: /tmp/flinkhistoryserver/
2.创建log目录:mkdir $FLINK_HOME/log
3.启动进程 historyserver.sh start
4.登陆historyserver,如果页面无法直接连接(能够连接请忽略),执行以下步骤:
a.确认配置项“jobmanager.web.ssl.enabled”的值是否是“false”,若不是,请修改为“false”。
b.确认配置项“jobmanager.web.access-control-allow-origin”和“jobmanager.web.allow-access-address”中是否已经添加浏览器所在的计算机IP地址。如果没有添加,可以通过这两项配置项进行添加。例如:
jobmanager.web.access-control-allow-origin: 浏览器所在的计算机IP地址
jobmanager.web.allow-access-address: 浏览器所在的计算机IP地址
- 点赞
- 收藏
- 关注作者
评论(0)