Flink History Server未显示运行的应用程序

Question

我正在尝试配置Flink History Server。我在这里遵循了Flink文件。我能够提出历史记录服务器，但只能看到完成的作业，而不是跑步的作业。我是否缺少某些内容，或者只是在历史服务器中显示完整的作业。请帮助。

目前在集群中的作业：

localhost：8081/joboverview

{
    "running": [
        {
            "jid": "e4e6edb76b887054d7aca460b7136937",
            "name": "Filter",
            "state": "RUNNING",
            "start-time": 1505971363801,
            "end-time": -1,
            "duration": 11588615,
            "last-modification": 1505971363832,
            "tasks": {
                "total": 1,
                "pending": 0,
                "running": 1,
                "finished": 0,
                "canceling": 0,
                "canceled": 0,
                "failed": 0
            }
        }
    ],
    "finished": [
        {
            "jid": "ec16f4cf01192268150c750966cefd0d",
            "name": "Flink Java Job at Thu Sep 21 10:52:09 IST 2017",
            "state": "FINISHED",
            "start-time": 1505971329989,
            "end-time": 1505971330746,
            "duration": 757,
            "last-modification": 1505971330746,
            "tasks": {
                "total": 3,
                "pending": 0,
                "running": 0,
                "finished": 3,
                "canceling": 0,
                "canceled": 0,
                "failed": 0
            }
        }
    ]
}

历史服务器中可用的作业

localhost：8082/joboverview

{
    "running": [],
    "finished": [
        {
            "jid": "ec16f4cf01192268150c750966cefd0d",
            "name": "Flink Java Job at Thu Sep 21 10:52:09 IST 2017",
            "state": "FINISHED",
            "start-time": 1505971329989,
            "end-time": 1505971330746,
            "duration": 757,
            "last-modification": 1505971330746,
            "tasks": {
                "total": 3,
                "pending": 0,
                "running": 0,
                "finished": 3,
                "canceling": 0,
                "canceled": 0,
                "failed": 0
            }
        }
    ]
}

Flink History Server配置：

#==============================================================================
# HistoryServer
#==============================================================================
# The HistoryServer is started and stopped via bin/historyserver.sh (start|stop)
# Directory to upload completed jobs to. Add this directory to the list of
# monitored directories of the HistoryServer as well (see below).
jobmanager.archive.fs.dir: hdfs://<hdfs>:8020/sax/flink/jobmanager
# The address under which the web-based HistoryServer listens.
historyserver.web.address: localhost
# The port under which the web-based HistoryServer listens.
historyserver.web.port: 8082
# Comma separated list of directories to monitor for completed jobs.
historyserver.archive.fs.dir: hdfs://<hdfs>:8020/sax/flink/jobmanager
# Interval in milliseconds for refreshing the monitored directories.
historyserver.archive.fs.refresh-interval: 10000

Answer 1

您链接的Flink网站的第一行：

flink具有可用于查询统计信息的历史服务器 已完成的工作已关闭相应的flink群集后 下来。

还指出

历史程序允许您查询状态和统计信息 完成的作业已由JobManager存档。

现在，从我的看来，您还可以访问使用" Localhost：8081/jobsoverview"访问的监视API，如果您只想访问可以使用"/jobsoverview/running" URI访问它们的运行作业，则

您可以在此处的监视API链接中找到更多信息。