org.apache.flink.runtime.client

Class JobClient

java.lang.Object

org.apache.flink.runtime.client.JobClient

public class JobClient
extends Object

The JobClient bridges between the JobManager's asynchronous actor messages and the synchronous method calls to trigger.

Constructor Summary

Constructors

Constructor and Description
JobClient()

Method Summary

Modifier and Type	Method and Description
static InetSocketAddress	getJobManagerAddress(org.apache.flink.configuration.Configuration config) Extracts the JobManager's Akka URL from the configuration.
static akka.actor.ActorSystem	startJobClientActorSystem(org.apache.flink.configuration.Configuration config)
static SerializedJobExecutionResult	submitJobAndWait(akka.actor.ActorSystem actorSystem, akka.actor.ActorRef jobManager, JobGraph jobGraph, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutLogUpdates) Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to the JobManager.
static void	submitJobDetached(akka.actor.ActorRef jobManager, JobGraph jobGraph, scala.concurrent.duration.FiniteDuration timeout) Submits a job in detached mode.
static void	uploadJarFiles(JobGraph jobGraph, akka.actor.ActorRef jobManager, scala.concurrent.duration.FiniteDuration timeout) Uploads the specified jar files of the [[JobGraph]] jobGraph to the BlobServer of the JobManager.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobClient

public JobClient()

Method Detail

startJobClientActorSystem

public static akka.actor.ActorSystem startJobClientActorSystem(org.apache.flink.configuration.Configuration config)
                                                        throws IOException

Throws:

IOException

getJobManagerAddress

public static InetSocketAddress getJobManagerAddress(org.apache.flink.configuration.Configuration config)
                                              throws IOException

Extracts the JobManager's Akka URL from the configuration. If localActorSystem is true, then the JobClient is executed in the same actor system as the JobManager. Thus, they can communicate locally.

Parameters:

config - Configuration object containing all user provided configuration values

Returns:

The socket address of the JobManager actor system

Throws:

IOException

submitJobAndWait

public static SerializedJobExecutionResult submitJobAndWait(akka.actor.ActorSystem actorSystem,
                                                            akka.actor.ActorRef jobManager,
                                                            JobGraph jobGraph,
                                                            scala.concurrent.duration.FiniteDuration timeout,
                                                            boolean sysoutLogUpdates)
                                                     throws JobExecutionException

Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to the JobManager. The method blocks until the job has finished or the JobManager is no longer alive. In the former case, the [[SerializedJobExecutionResult]] is returned and in the latter case a [[JobExecutionException]] is thrown.

Parameters:

actorSystem - The actor system that performs the communication.

jobManager - The JobManager that should execute the job.

jobGraph - JobGraph describing the Flink job

timeout - Timeout for futures

Returns:

The job execution result

Throws:

JobExecutionException - Thrown if the job execution fails.

submitJobDetached

public static void submitJobDetached(akka.actor.ActorRef jobManager,
                                     JobGraph jobGraph,
                                     scala.concurrent.duration.FiniteDuration timeout)
                              throws JobExecutionException

Submits a job in detached mode. The method sends the JobGraph to the JobManager and waits for the answer whether teh job could be started or not.

Parameters:

jobGraph - The job

timeout - Timeout in which the JobManager must have responded.

Throws:

JobExecutionException

uploadJarFiles

public static void uploadJarFiles(JobGraph jobGraph,
                                  akka.actor.ActorRef jobManager,
                                  scala.concurrent.duration.FiniteDuration timeout)
                           throws IOException

Uploads the specified jar files of the [[JobGraph]] jobGraph to the BlobServer of the JobManager. The respective port is retrieved from the JobManager. This function issues a blocking call.

Parameters:

jobGraph - Flink job containing the information about the required jars

jobManager - ActorRef of the JobManager.

timeout - Timeout for futures

Throws:

IOException - Thrown, if the file upload to the JobManager failed.