Flink v6 rest api: как получить все законченные / выполненные задания

Question

В Flink v-1.4 был API для отдыха, чтобы получить все законченные / завершенные задания:

/ joboverview / пройдено

Как я вижу, в v нет таких API.-1.6, как я могу получить ТОЛЬКО законченные / завершенные задания.

Answer 1

Вы можете сделать это, настроив и запустив History Server .

В 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.