弗林克历史服务

flink任务停止后,JobManager会将已完成任务的统计数据存档,历史服务进程可以在任务停止后查询该任务的统计数据。比如:最后一个检查点,任务运行时的相关配置。

默认引导端口8082:

查看/tmp/flick-we b-history-7586 c 510-103 f-4443-8252-59 c 56d 86930 e历史服务存储文件夹的内容。

在历史服务存储文件中,存储了用于页面展示的模板配置。历史任务信息存储在作业路径中,其中包含已完成的作业。每次启动时,将从historyserver.archive.fs.dir中提取所有任务元数据信息

每个任务文件夹都包含一些我们需要获取的信息,当我们通过restAPI获取时间指示器时会返回这些信息。

任务运行时,生成的checpoint路径通过RestAPI存储在DB中,这样任务就可以按照路径继续运行。当任务结束时,可能无法及时从正在运行的任务中提取最后一个检查点信息。此时需要从历史服务中获取“已完成”的路径,导致获取数据失败。检查hdfs没有这个路径,最后定位到jobmanager.archive.fs.dir参数没有配置。