Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.waitUntilJobInitializationFinished(SupplierWithException<JobStatus,Exception> jobStatusSupplier,
SupplierWithException<JobResult,Exception> jobResultSupplier,
ClassLoader userCodeClassloader)
This method blocks until the job status is not INITIALIZING anymore.
|
Modifier and Type | Method and Description |
---|---|
static UnsuccessfulExecutionException |
UnsuccessfulExecutionException.fromJobResult(JobResult result,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
ApplicationDispatcherGatewayServiceFactory.create(DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
MiniClusterClient.requestJobResult(JobID jobId) |
CompletableFuture<JobResult> |
ClusterClient.requestJobResult(JobID jobId)
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
RestClusterClient.requestJobResult(JobID jobId)
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
MiniDispatcher.requestJobResult(JobID jobId,
Time timeout) |
CompletableFuture<JobResult> |
Dispatcher.requestJobResult(JobID jobId,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
MiniDispatcher |
JobDispatcherFactory.createDispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents) |
StandaloneDispatcher |
SessionDispatcherFactory.createDispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents) |
Dispatcher |
DispatcherFactory.createDispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
PartialDispatcherServicesWithJobPersistenceComponents partialDispatcherServicesWithJobPersistenceComponents)
Create a
Dispatcher . |
Constructor and Description |
---|
MiniDispatcher(RpcService rpcService,
DispatcherId fencingToken,
DispatcherServices dispatcherServices,
JobGraph jobGraph,
JobResult recoveredDirtyJob,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
ClusterEntrypoint.ExecutionMode executionMode) |
MiniDispatcher(RpcService rpcService,
DispatcherId fencingToken,
DispatcherServices dispatcherServices,
JobGraph jobGraph,
JobResult recoveredDirtyJob,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
ResourceCleanerFactory resourceCleanerFactory,
ClusterEntrypoint.ExecutionMode executionMode) |
Constructor and Description |
---|
Dispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobs,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
DispatcherServices dispatcherServices) |
Dispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobs,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
DispatcherServices dispatcherServices,
JobManagerRunnerRegistry jobManagerRunnerRegistry,
ResourceCleanerFactory resourceCleanerFactory) |
StandaloneDispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
DispatcherBootstrapFactory dispatcherBootstrapFactory,
DispatcherServices dispatcherServices) |
Modifier and Type | Method and Description |
---|---|
JobManagerRunner |
CleanupRunnerFactory.create(JobResult jobResult,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Configuration configuration,
Executor cleanupExecutor) |
CheckpointResourcesCleanupRunner |
CheckpointResourcesCleanupRunnerFactory.create(JobResult jobResult,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Configuration configuration,
Executor cleanupExecutor) |
Constructor and Description |
---|
CheckpointResourcesCleanupRunner(JobResult jobResult,
CheckpointRecoveryFactory checkpointRecoveryFactory,
SharedStateRegistryFactory sharedStateRegistryFactory,
Configuration jobManagerConfiguration,
Executor cleanupExecutor,
long initializationTimestamp) |
Modifier and Type | Method and Description |
---|---|
AbstractDispatcherLeaderProcess.DispatcherGatewayService |
AbstractDispatcherLeaderProcess.DispatcherGatewayServiceFactory.create(DispatcherId dispatcherId,
Collection<JobGraph> recoveredJobs,
Collection<JobResult> recoveredDirtyJobResults,
JobGraphWriter jobGraphWriter,
JobResultStore jobResultStore) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobResultEntry.getJobResult() |
Modifier and Type | Method and Description |
---|---|
Set<JobResult> |
JobResultStore.getDirtyResults()
Get the persisted
JobResult instances that are marked as dirty . |
Set<JobResult> |
AbstractThreadsafeJobResultStore.getDirtyResults() |
protected abstract Set<JobResult> |
AbstractThreadsafeJobResultStore.getDirtyResultsInternal() |
Set<JobResult> |
FileSystemJobResultStore.getDirtyResultsInternal() |
Constructor and Description |
---|
JobResultEntry(JobResult jobResult) |
Modifier and Type | Method and Description |
---|---|
Set<JobResult> |
EmbeddedJobResultStore.getDirtyResultsInternal() |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobResult.Builder.build() |
static JobResult |
JobResult.createFrom(AccessExecutionGraph accessExecutionGraph)
Creates the
JobResult from the given AccessExecutionGraph which must be in a
globally terminal state. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
MiniCluster.requestJobResult(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobExecutionResultResponseBody.getJobExecutionResult() |
JobResult |
JobExecutionResultResponseBody.resource() |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResultResponseBody |
JobExecutionResultResponseBody.created(JobResult jobExecutionResult) |
Constructor and Description |
---|
JobExecutionResultResponseBody(QueueStatus status,
JobResult jobExecutionResult) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobResultDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser p,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
void |
JobResultSerializer.serialize(JobResult result,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator gen,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider provider) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
RestfulGateway.requestJobResult(JobID jobId,
Time timeout)
Requests the
JobResult of a job specified by the given jobId. |
CompletableFuture<JobResult> |
NonLeaderRetrievalRestfulGateway.requestJobResult(JobID jobId,
Time timeout) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.