org.apache.flink.runtime.jobmanager.web

Class WebInfoServer

java.lang.Object

org.apache.flink.runtime.jobmanager.web.WebInfoServer

public class WebInfoServer
extends Object

This class sets up a web-server that contains a web frontend to display information about running jobs. It instantiates and configures an embedded jetty server.

Constructor Summary

Constructors

Constructor and Description
WebInfoServer(org.apache.flink.configuration.Configuration config, akka.actor.ActorRef jobmanager, akka.actor.ActorRef archive) Creates a new web info server.

Method Summary

Modifier and Type	Method and Description
int	getServerPort()
void	start() Starts the web frontend server.
void	stop() Stop the webserver

Methods inherited from class java.lang.Object

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

Constructor Detail

WebInfoServer

public WebInfoServer(org.apache.flink.configuration.Configuration config,
                     akka.actor.ActorRef jobmanager,
                     akka.actor.ActorRef archive)
              throws IOException

Creates a new web info server. The server runs the servlets that implement the logic to list all present information concerning the job manager

Parameters:

config - The Flink configuration.

jobmanager - The ActorRef to the JobManager actor

archive - The ActorRef to the archive for old jobs

Throws:

IOException - Thrown, if the server setup failed for an I/O related reason.

Method Detail

start

public void start()
           throws Exception

Starts the web frontend server.

Throws:

Exception - Thrown, if the start fails.

stop

public void stop()
          throws Exception

Stop the webserver

Throws:

Exception

getServerPort

public int getServerPort()