org.apache.flink.runtime.webmonitor.history

Class HistoryServer

java.lang.Object

org.apache.flink.runtime.webmonitor.history.HistoryServer

public class HistoryServer
extends Object

The HistoryServer provides a WebInterface and REST API to retrieve information about finished jobs for which the JobManager may have already shut down.

The HistoryServer regularly checks a set of directories for job archives created by the FsJobArchivist and caches these in a local directory. See HistoryServerArchiveFetcher.

All configuration options are defined inHistoryServerOptions.

The WebInterface only displays the "Completed Jobs" page.

The REST API is limited to

• /config
• /joboverview
• /jobs/:jobid/*

and relies on static files that are served by the HistoryServerStaticFileServerHandler.

Constructor Summary

Constructors

Constructor and Description
HistoryServer(Configuration config)
HistoryServer(Configuration config, CountDownLatch numFinishedPolls)

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HistoryServer

public HistoryServer(Configuration config)
              throws IOException,
                     FlinkException

Throws:

IOException

FlinkException

HistoryServer

public HistoryServer(Configuration config,
                     CountDownLatch numFinishedPolls)
              throws IOException,
                     FlinkException

Throws:

IOException

FlinkException

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

run

public void run()