之前我們做了Flink的開發，開發完成之后就需要進行監控。

Flink 有一個History Server可以在相關Flink 集群關閉之后，還可以查看一些信息。也就是一些作業運行完成之后，可以用History Server查看運行的統計信息。同時，還暴露了一些RestAPI，允許http進行請求。
修改配置文件conf/flink-conf.yaml：

jobmanager.archive.fs.dir: hdfs://swarm-manager:9000/completed-jobs/ historyserver.web.address: 0.0.0.0 historyserver.web.port: 8083 historyserver.archive.fs.dir: hdfs://swarm-manager:9000/completed-jobs/ historyserver.archive.fs.refresh-interval: 10000

啟動HistoryServer

瀏覽器中輸入地址：http://swarm-manager:8083



查看HDFS中的文件：

因為還沒有執行作業，所以沒有生成completed-jobs文件

測試History Server

執行命令./bin/flink run -m yarn-cluster -yn 1 ./examples/batch/WordCount.jar
瀏覽器中輸入：http://swarm-manager:8083

然后在hdfs中查看：

API

請求發送http://hostname:8083(這個在配置文件中設置的)/jobs
URI：

• /config
• /jobs/overview
• /jobs/< jobid>
• /jobs/< jobid>/vertices
• /jobs/< jobid>/config
• /jobs/< jobid>/exceptions
• /jobs/< jobid>/accumulators
• /jobs/< jobid>/vertices/< vertexid>
• /jobs/< jobid>/vertices/< vertexid>/subtasktimes
• /jobs/< jobid>/vertices/< vertexid>/taskmanagers
• /jobs/< jobid>/vertices/< vertexid>/accumulators
• /jobs/< jobid>/vertices/< vertexid>/subtasks/accumulators
• /jobs/< jobid>/vertices/< vertexid>/subtasks/< subtasknum>
• /jobs/< jobid>/vertices/< vertexid>/subtasks/< subtasknum>/attempts/< attempt>
• /jobs/< jobid>/vertices/< vertexid>/subtasks/< subtasknum>/attempts/< attempt>/accumulators
• /jobs/< jobid>/plan
  例如： http://hostname:port/jobs/7684be6004e4e955c2a558a9bc463f65/exceptions
  

總結

以上是生活随笔為你收集整理的Apache Flink 零基础入门（二十一）Flink HistoryServer概述与配置的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。