Modifier and Type | Method and Description |
---|---|
StandaloneClusterClient |
StandaloneClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
ClientType |
ClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph)
Deploys a per-job cluster with the given job on the cluster.
|
RestClusterClient |
Flip6StandaloneClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
ClusterClient.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan,
SavepointRestoreSettings savepointSettings) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ClusterClient.run(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph blocking.
|
JobSubmissionResult |
ClusterClient.runDetached(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph detached.
|
protected JobSubmissionResult |
StandaloneClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected abstract JobSubmissionResult |
ClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
Modifier and Type | Method and Description |
---|---|
protected JobSubmissionResult |
RestClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
MesosJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
abstract JobGraph |
StreamingPlan.getJobGraph() |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program)
Translates a
OptimizedPlan into a
JobGraph . |
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program,
JobID jobId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
AkkaJobManagerGateway.submitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
static JobListeningContext |
JobClient.submitJob(akka.actor.ActorSystem actorSystem,
Configuration config,
HighAvailabilityServices highAvailabilityServices,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Submits a job to a Flink cluster (non-blocking) and returns a JobListeningContext which can be
passed to
awaitJobResult to get the result of the submission. |
static JobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
Configuration config,
HighAvailabilityServices highAvailabilityServices,
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 |
JobClient.submitJobDetached(JobManagerGateway jobManagerGateway,
Configuration config,
JobGraph jobGraph,
Time timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
Modifier and Type | Method and Description |
---|---|
protected JobManagerRunner |
StandaloneDispatcher.createJobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
JobManagerServices jobManagerServices,
MetricRegistry metricRegistry,
OnCompletionActions onCompleteActions,
FatalErrorHandler fatalErrorHandler) |
protected abstract JobManagerRunner |
Dispatcher.createJobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
JobManagerServices jobManagerServices,
MetricRegistry metricRegistry,
OnCompletionActions onCompleteActions,
FatalErrorHandler fatalErrorHandler) |
CompletableFuture<Acknowledge> |
DispatcherGateway.submitJob(JobGraph jobGraph,
Time timeout)
Submit a job to the dispatcher.
|
CompletableFuture<Acknowledge> |
Dispatcher.submitJob(JobGraph jobGraph,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
protected abstract JobGraph |
JobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time timeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
BlobWriter blobWriter,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
Modifier and Type | Method and Description |
---|---|
static String |
JsonPlanGenerator.generatePlan(JobGraph jg) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
SubmittedJobGraph.getJobGraph()
Returns the submitted
JobGraph . |
Constructor and Description |
---|
SubmittedJobGraph(JobGraph jobGraph,
org.apache.flink.runtime.jobmanager.JobInfo jobInfo)
Creates a
SubmittedJobGraph . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
JobManagerGateway.submitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour,
Time timeout)
Submits a job to the JobManager.
|
Constructor and Description |
---|
JobManagerRunner(ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices haServices,
HeartbeatServices heartbeatServices,
JobManagerServices jobManagerServices,
MetricRegistry metricRegistry,
OnCompletionActions toNotifyOnComplete,
FatalErrorHandler errorHandler)
Exceptions that occur while creating the JobManager or JobManagerRunner are directly
thrown and not reported to the given
FatalErrorHandler . |
JobMaster(RpcService rpcService,
ResourceID resourceId,
JobGraph jobGraph,
Configuration configuration,
HighAvailabilityServices highAvailabilityService,
HeartbeatServices heartbeatServices,
ScheduledExecutorService executor,
BlobServer blobServer,
BlobLibraryCacheManager libraryCacheManager,
RestartStrategyFactory restartStrategyFactory,
Time rpcAskTimeout,
JobManagerMetricGroup jobManagerMetricGroup,
OnCompletionActions jobCompletionActions,
FatalErrorHandler errorHandler,
ClassLoader userCodeLoader) |
Modifier and Type | Method and Description |
---|---|
JobManagerJobMetricGroup |
JobManagerMetricGroup.addJob(JobGraph job) |
Modifier and Type | Method and Description |
---|---|
void |
MiniCluster.runDetached(JobGraph job)
This method executes a job in detached mode.
|
void |
MiniClusterJobDispatcher.runDetached(JobGraph job)
This method executes a job in detached mode.
|
JobExecutionResult |
MiniCluster.runJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
JobExecutionResult |
MiniClusterJobDispatcher.runJobBlocking(JobGraph job)
This method runs a job in blocking mode.
|
Constructor and Description |
---|
JobSubmitRequestBody(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
protected Tuple2<JobGraph,ClassLoader> |
JarActionHandler.getJobGraphAndClassLoader(org.apache.flink.runtime.webmonitor.handlers.JarActionHandler.JarActionHandlerConfig config) |
Modifier and Type | Method and Description |
---|---|
static JobGraph |
StreamingJobGraphGenerator.createJobGraph(StreamGraph streamGraph) |
JobGraph |
StreamGraph.getJobGraph()
Gets the assembled
JobGraph . |
Modifier and Type | Method and Description |
---|---|
protected YarnClusterClient |
AbstractYarnClusterDescriptor.deployInternal(ClusterSpecification clusterSpecification,
String yarnClusterEntrypoint,
JobGraph jobGraph)
This method will block until the ApplicationMaster/JobManager have been
deployed on YARN.
|
YarnClusterClient |
YarnClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
YarnClusterClient |
AbstractYarnClusterDescriptor.deployJobCluster(ClusterSpecification clusterSpecification,
JobGraph jobGraph) |
org.apache.hadoop.yarn.api.records.ApplicationReport |
AbstractYarnClusterDescriptor.startAppMaster(String yarnClusterEntrypoint,
JobGraph jobGraph,
org.apache.hadoop.yarn.client.api.YarnClient yarnClient,
org.apache.hadoop.yarn.client.api.YarnClientApplication yarnApplication,
ClusterSpecification clusterSpecification) |
protected JobSubmissionResult |
YarnClusterClientV2.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected JobSubmissionResult |
YarnClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
protected JobGraph |
YarnJobClusterEntrypoint.retrieveJobGraph(Configuration configuration) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.