flinkv6restapi:如何获得所有已完成/已完成的作业

qojgxg4l  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(390)

在flink v-1.4中,有一个rest api来获取所有已完成/已完成的作业:
/工作概述/已完成
正如我所看到的,在v-1.6中没有这样的api,我如何才能只获得完成的/已完成的作业。

eimct9ow

eimct9ow1#

您可以通过配置和运行历史服务器来实现这一点。
在flink-conf.yaml中,您将找到历史服务器的一个部分。为了在本地进行测试,我尝试了以下设置:


# ==============================================================================

# 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: file:///tmp/completed-jobs/

# The address under which the web-based HistoryServer listens.

# historyserver.web.address: 0.0.0.0

# 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: file:///tmp/completed-jobs/

# Interval in milliseconds for refreshing the monitored directories.

historyserver.archive.fs.refresh-interval: 10000

我创造了 /tmp/completed-jobs ,重新启动了集群,并启动了历史服务器,之后我可以在上看到已完成的作业 http://localhost:8082 (html)和 http://localhost:8082/jobs/overview (json)。
有关api的更多信息,请参阅可用请求列表。

相关问题