Uses of Class
org.apache.flink.api.common.JobStatus

Packages that use JobStatus

Package	Description
org.apache.flink.api.common
org.apache.flink.client
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.core.execution
org.apache.flink.kubernetes.highavailability
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.client
org.apache.flink.runtime.clusterframework	This package contains the cluster resource management functionality.
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.cleanup
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.messages	This package contains the messages that are sent between Flink's distributed components to coordinate the distributed operations.
org.apache.flink.runtime.messages.webmonitor	This package contains the actor messages that are sent between the JobManager and components that are interested in the status of the JobManager.
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.metrics
org.apache.flink.runtime.webmonitor

Uses of JobStatus in org.apache.flink.api.common

Methods in org.apache.flink.api.common that return JobStatus

Modifier and Type	Method and Description
static JobStatus	JobStatus.valueOf(String name) Returns the enum constant of this type with the specified name.
static JobStatus[]	JobStatus.values() Returns an array containing the constants of this enum type, in the order they are declared.

Uses of JobStatus in org.apache.flink.client

Method parameters in org.apache.flink.client with type arguments of type JobStatus

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.

Uses of JobStatus in org.apache.flink.client.deployment

Methods in org.apache.flink.client.deployment that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	ClusterClientJobClientAdapter.getJobStatus()

Uses of JobStatus in org.apache.flink.client.deployment.application

Methods in org.apache.flink.client.deployment.application that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	EmbeddedJobClient.getJobStatus()
CompletableFuture<JobStatus>	WebSubmissionJobClient.getJobStatus()

Uses of JobStatus in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	ClusterClient.getJobStatus(JobID jobId) Requests the JobStatus of the job with the given JobID.
CompletableFuture<JobStatus>	MiniClusterClient.getJobStatus(JobID jobId)

Uses of JobStatus in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	RestClusterClient.getJobStatus(JobID jobId)

Uses of JobStatus in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	JobClient.getJobStatus() Requests the JobStatus of the associated job.

Uses of JobStatus in org.apache.flink.kubernetes.highavailability

Methods in org.apache.flink.kubernetes.highavailability with parameters of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<Void>	KubernetesCheckpointIDCounter.shutdown(JobStatus jobStatus)

Uses of JobStatus in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return types with arguments of type JobStatus

Modifier and Type	Method and Description
Optional<JobStatus>	EmbeddedCompletedCheckpointStore.getShutdownStatus()

Methods in org.apache.flink.runtime.checkpoint with parameters of type JobStatus

Modifier and Type	Method and Description
void	CheckpointCoordinatorDeActivator.jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp)
Checkpoint.DiscardObject	CompletedCheckpoint.markAsDiscardedOnShutdown(JobStatus jobStatus)
boolean	CompletedCheckpoint.shouldBeDiscardedOnShutdown(JobStatus jobStatus)
CompletableFuture<Void>	StandaloneCheckpointIDCounter.shutdown(JobStatus jobStatus)
CompletableFuture<Void>	CheckpointIDCounter.shutdown(JobStatus jobStatus) Shuts the CheckpointIDCounter service.
CompletableFuture<Void>	ZooKeeperCheckpointIDCounter.shutdown(JobStatus jobStatus)
CompletableFuture<Void>	DeactivatedCheckpointIDCounter.shutdown(JobStatus jobStatus)
void	StandaloneCompletedCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner)
void	DeactivatedCheckpointCompletedCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner)
void	CompletedCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner) Shuts down the store.
void	AbstractCompleteCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner)
void	EmbeddedCompletedCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner)
void	DefaultCompletedCheckpointStore.shutdown(JobStatus jobStatus, CheckpointsCleaner checkpointsCleaner)

Uses of JobStatus in org.apache.flink.runtime.client

Methods in org.apache.flink.runtime.client that return JobStatus

Modifier and Type	Method and Description
JobStatus	JobStatusMessage.getJobState()

Constructors in org.apache.flink.runtime.client with parameters of type JobStatus

Constructor and Description
JobStatusMessage(JobID jobId, String jobName, JobStatus jobState, long startTime)

Uses of JobStatus in org.apache.flink.runtime.clusterframework

Methods in org.apache.flink.runtime.clusterframework that return JobStatus

Modifier and Type	Method and Description
JobStatus	ApplicationStatus.deriveJobStatus() Derives the JobStatus from the ApplicationStatus.

Methods in org.apache.flink.runtime.clusterframework with parameters of type JobStatus

Modifier and Type	Method and Description
static ApplicationStatus	ApplicationStatus.fromJobStatus(JobStatus jobStatus) Derives the ApplicationStatus that should be used for a job that resulted in the given job status.

Uses of JobStatus in org.apache.flink.runtime.dispatcher

Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	Dispatcher.requestJobStatus(JobID jobId, Time timeout)

Methods in org.apache.flink.runtime.dispatcher with parameters of type JobStatus

Modifier and Type	Method and Description
protected void	Dispatcher.runPostJobGloballyTerminated(JobID jobId, JobStatus jobStatus)
protected void	MiniDispatcher.runPostJobGloballyTerminated(JobID jobId, JobStatus jobStatus)

Uses of JobStatus in org.apache.flink.runtime.dispatcher.cleanup

Methods in org.apache.flink.runtime.dispatcher.cleanup that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	CheckpointResourcesCleanupRunner.requestJobStatus(Time timeout)

Uses of JobStatus in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return JobStatus

Modifier and Type	Method and Description
JobStatus	AccessExecutionGraph.getState() Returns the current JobStatus for this execution graph.
JobStatus	JobStatusProvider.getState() Returns the current JobStatus for this execution graph.
JobStatus	DefaultExecutionGraph.getState()
JobStatus	ArchivedExecutionGraph.getState()
JobStatus	DefaultExecutionGraph.waitUntilTerminal()
JobStatus	ExecutionGraph.waitUntilTerminal()

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	DefaultExecutionGraph.getTerminationFuture()
CompletableFuture<JobStatus>	ExecutionGraph.getTerminationFuture() Returns the termination future of this ExecutionGraph.

Methods in org.apache.flink.runtime.executiongraph with parameters of type JobStatus

Modifier and Type	Method and Description
static ArchivedExecutionGraph	ArchivedExecutionGraph.createFrom(ExecutionGraph executionGraph, JobStatus statusOverride) Create a ArchivedExecutionGraph from the given ExecutionGraph.
static ArchivedExecutionGraph	ArchivedExecutionGraph.createSparseArchivedExecutionGraph(JobID jobId, String jobName, JobStatus jobStatus, Throwable throwable, JobCheckpointingSettings checkpointingSettings, long initializationTimestamp) Create a sparse ArchivedExecutionGraph for a job.
long	AccessExecutionGraph.getStatusTimestamp(JobStatus status) Returns the timestamp for the given JobStatus.
long	JobStatusProvider.getStatusTimestamp(JobStatus status) Returns the timestamp for the given JobStatus.
long	DefaultExecutionGraph.getStatusTimestamp(JobStatus status)
long	ArchivedExecutionGraph.getStatusTimestamp(JobStatus status)
void	JobStatusListener.jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp) This method is called whenever the status of the job changes.
boolean	DefaultExecutionGraph.transitionState(JobStatus current, JobStatus newState)
boolean	ExecutionGraph.transitionState(JobStatus current, JobStatus newState)

Constructors in org.apache.flink.runtime.executiongraph with parameters of type JobStatus

Constructor and Description

ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, ErrorInfo failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, CheckpointStatsSnapshot checkpointStatsSnapshot, String stateBackendName, String checkpointStorageName, TernaryBoolean stateChangelogEnabled, String changelogStorageName)

Uses of JobStatus in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	JobManagerRunner.requestJobStatus(Time timeout) Requests the current job status.
CompletableFuture<JobStatus>	JobMasterServiceLeadershipRunner.requestJobStatus(Time timeout)
CompletableFuture<JobStatus>	JobMasterGateway.requestJobStatus(Time timeout) Requests the current job status.
CompletableFuture<JobStatus>	JobMaster.requestJobStatus(Time timeout)

Uses of JobStatus in org.apache.flink.runtime.jobmaster.factories

Methods in org.apache.flink.runtime.jobmaster.factories with parameters of type JobStatus

Modifier and Type	Method and Description
ArchivedExecutionGraph	DefaultJobMasterServiceProcessFactory.createArchivedExecutionGraph(JobStatus jobStatus, Throwable cause)
ArchivedExecutionGraph	JobMasterServiceProcessFactory.createArchivedExecutionGraph(JobStatus jobStatus, Throwable cause) Creates an ArchivedExecutionGraph for the job for which this factory creates JobMasterServiceProcess with the given jobStatus and failure cause.

Uses of JobStatus in org.apache.flink.runtime.messages

Methods in org.apache.flink.runtime.messages that return JobStatus

Modifier and Type	Method and Description
JobStatus	FlinkJobTerminatedWithoutCancellationException.getJobStatus()

Constructors in org.apache.flink.runtime.messages with parameters of type JobStatus

Constructor and Description
FlinkJobTerminatedWithoutCancellationException(JobID jobId, JobStatus jobStatus)

Uses of JobStatus in org.apache.flink.runtime.messages.webmonitor

Methods in org.apache.flink.runtime.messages.webmonitor that return JobStatus

Modifier and Type	Method and Description
JobStatus	JobIdsWithStatusOverview.JobIdWithStatus.getJobStatus()
JobStatus	JobStatusInfo.getJobStatus()
JobStatus	JobDetails.getStatus()

Method parameters in org.apache.flink.runtime.messages.webmonitor with type arguments of type JobStatus

Modifier and Type	Method and Description
static JobsOverview	JobsOverview.create(Collection<JobStatus> allJobsStatus)

Constructors in org.apache.flink.runtime.messages.webmonitor with parameters of type JobStatus

Constructor and Description
JobDetails(JobID jobId, String jobName, long startTime, long endTime, long duration, JobStatus status, long lastUpdateTime, int[] tasksPerState, int numTasks)
JobDetails(JobID jobId, String jobName, long startTime, long endTime, long duration, JobStatus status, long lastUpdateTime, int[] tasksPerState, int numTasks, Map<String,Map<Integer,JobDetails.CurrentAttempts>> currentExecutionAttempts)
JobIdWithStatus(JobID jobId, JobStatus jobStatus)
JobStatusInfo(JobStatus jobStatus)

Uses of JobStatus in org.apache.flink.runtime.minicluster

Methods in org.apache.flink.runtime.minicluster that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	MiniClusterJobClient.getJobStatus()
CompletableFuture<JobStatus>	MiniCluster.getJobStatus(JobID jobId)

Uses of JobStatus in org.apache.flink.runtime.resourcemanager

Methods in org.apache.flink.runtime.resourcemanager with parameters of type JobStatus

Modifier and Type	Method and Description
void	ResourceManager.disconnectJobManager(JobID jobId, JobStatus jobStatus, Exception cause)
void	ResourceManagerGateway.disconnectJobManager(JobID jobId, JobStatus jobStatus, Exception cause) Disconnects a JobManager specified by the given resourceID from the ResourceManager.

Uses of JobStatus in org.apache.flink.runtime.rest.messages.job

Methods in org.apache.flink.runtime.rest.messages.job that return JobStatus

Modifier and Type	Method and Description
JobStatus	JobDetailsInfo.getJobStatus()

Methods in org.apache.flink.runtime.rest.messages.job that return types with arguments of type JobStatus

Modifier and Type	Method and Description
Map<JobStatus,Long>	JobDetailsInfo.getTimestamps()

Constructors in org.apache.flink.runtime.rest.messages.job with parameters of type JobStatus

Constructor and Description
JobDetailsInfo(JobID jobId, String name, boolean isStoppable, JobStatus jobStatus, long startTime, long endTime, long duration, long maxParallelism, long now, Map<JobStatus,Long> timestamps, Collection<JobDetailsInfo.JobVertexDetailsInfo> jobVertexInfos, Map<ExecutionState,Integer> jobVerticesPerState, String jsonPlan)

Constructor parameters in org.apache.flink.runtime.rest.messages.job with type arguments of type JobStatus

Constructor and Description
JobDetailsInfo(JobID jobId, String name, boolean isStoppable, JobStatus jobStatus, long startTime, long endTime, long duration, long maxParallelism, long now, Map<JobStatus,Long> timestamps, Collection<JobDetailsInfo.JobVertexDetailsInfo> jobVertexInfos, Map<ExecutionState,Integer> jobVerticesPerState, String jsonPlan)

Uses of JobStatus in org.apache.flink.runtime.scheduler

Methods in org.apache.flink.runtime.scheduler that return JobStatus

Modifier and Type	Method and Description
JobStatus	JobStatusStore.getState()
JobStatus	SchedulerNG.requestJobStatus()
JobStatus	SchedulerBase.requestJobStatus()

Methods in org.apache.flink.runtime.scheduler that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	SchedulerNG.getJobTerminationFuture()
CompletableFuture<JobStatus>	SchedulerBase.getJobTerminationFuture()

Methods in org.apache.flink.runtime.scheduler with parameters of type JobStatus

Modifier and Type	Method and Description
long	JobStatusStore.getStatusTimestamp(JobStatus status)
void	JobStatusStore.jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp)
protected void	SchedulerBase.transitionExecutionGraphState(JobStatus current, JobStatus newState)

Uses of JobStatus in org.apache.flink.runtime.scheduler.adaptive

Methods in org.apache.flink.runtime.scheduler.adaptive that return JobStatus

Modifier and Type	Method and Description
JobStatus	CreatingExecutionGraph.getJobStatus()
JobStatus	AdaptiveScheduler.requestJobStatus()

Methods in org.apache.flink.runtime.scheduler.adaptive that return types with arguments of type JobStatus

Modifier and Type	Method and Description
CompletableFuture<JobStatus>	AdaptiveScheduler.getJobTerminationFuture()

Methods in org.apache.flink.runtime.scheduler.adaptive with parameters of type JobStatus

Modifier and Type	Method and Description
ArchivedExecutionGraph	AdaptiveScheduler.getArchivedExecutionGraph(JobStatus jobStatus, Throwable cause)

Uses of JobStatus in org.apache.flink.runtime.scheduler.metrics

Methods in org.apache.flink.runtime.scheduler.metrics with parameters of type JobStatus

Modifier and Type	Method and Description
void	JobStatusMetrics.jobStatusChanges(JobID jobId, JobStatus newJobStatus, long timestamp)

Uses of JobStatus in org.apache.flink.runtime.webmonitor

Methods in org.apache.flink.runtime.webmonitor that return types with arguments of type JobStatus

Modifier and Type	Method and Description
default CompletableFuture<JobStatus>	RestfulGateway.requestJobStatus(JobID jobId, Time timeout) Request the JobStatus of the given job.