public class JobClient extends Object
Constructor and Description |
---|
JobClient() |
Modifier and Type | Method and Description |
---|---|
static akka.actor.ActorSystem |
startJobClientActorSystem(Configuration config) |
static JobExecutionResult |
submitJobAndWait(akka.actor.ActorSystem actorSystem,
LeaderRetrievalService leaderRetrievalService,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager.
|
static void |
submitJobDetached(ActorGateway jobManagerGateway,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
static void |
uploadJarFiles(JobGraph jobGraph,
ActorGateway jobManagerGateway,
scala.concurrent.duration.FiniteDuration timeout)
Uploads the specified jar files of the [[JobGraph]] jobGraph to the BlobServer of the
JobManager.
|
public static akka.actor.ActorSystem startJobClientActorSystem(Configuration config) throws IOException
IOException
public static JobExecutionResult submitJobAndWait(akka.actor.ActorSystem actorSystem, LeaderRetrievalService leaderRetrievalService, JobGraph jobGraph, scala.concurrent.duration.FiniteDuration timeout, boolean sysoutLogUpdates, ClassLoader classLoader) throws JobExecutionException
actorSystem
- The actor system that performs the communication.leaderRetrievalService
- Leader retrieval service which used to find the current leading
JobManagerjobGraph
- JobGraph describing the Flink jobtimeout
- Timeout for futuressysoutLogUpdates
- prints log updates to system out if trueJobExecutionException
- Thrown if the job
execution fails.public static void submitJobDetached(ActorGateway jobManagerGateway, JobGraph jobGraph, scala.concurrent.duration.FiniteDuration timeout, ClassLoader classLoader) throws JobExecutionException
jobManagerGateway
- Gateway to the JobManager which will execute the jobsjobGraph
- The jobtimeout
- Timeout in which the JobManager must have responded.JobExecutionException
public static void uploadJarFiles(JobGraph jobGraph, ActorGateway jobManagerGateway, scala.concurrent.duration.FiniteDuration timeout) throws IOException
jobGraph
- Flink job containing the information about the required jarsjobManagerGateway
- Gateway to the JobManager.timeout
- Timeout for futuresIOException
- Thrown, if the file upload to the JobManager failed.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.