Flinkヒストリサーバーに実行中のアプリケーションが表示されない

Question

flinkヒストリサーバーを構成しようとしています。私はフリンク文書hereに従った。ヒストリサーバーを起動できますが、実行中のジョブではなく、完了したジョブしか見ることができませんでした。何かが欠けているのか、それとも完了したジョブだけが履歴サーバーに表示されているのでしょうか。親切に助けてください。

ジョブズ現在クラスタ内：

は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履歴サーバ設定：

#============================================================================== 
# 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クラスタがシャットダウンされた後に終了します。 down。また

HistoryServerはあなたがステータスとJobManagerでアーカイブされた 完了したジョブの統計情報を照会することができますことを述べ

。

私が見るところでは、 "localhost：8081/joboverview"でアクセスしたモニタリングAPIにアクセスできます。実行中のジョブだけにアクセスしたい場合は、 "/ joboverview/「実行中」uri

詳細については、Monitoring APIリンクを参照してください。