Uses of Class
org.apache.flink.runtime.JobException

Packages that use JobException

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmanager.scheduler
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.scheduler

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

Methods in org.apache.flink.runtime.executiongraph that throw JobException

Modifier and Type	Method	Description
void	DefaultExecutionGraph.attachJobGraph(List<JobVertex> verticesToAttach, JobManagerJobMetricGroup jobManagerJobMetricGroup)
void	ExecutionGraph.attachJobGraph(List<JobVertex> topologicallySorted, JobManagerJobMetricGroup jobManagerJobMetricGroup)
static DefaultExecutionGraph	DefaultExecutionGraphBuilder.buildGraph(JobGraph jobGraph, org.apache.flink.configuration.Configuration jobManagerConfig, ScheduledExecutorService futureExecutor, Executor ioExecutor, ClassLoader classLoader, CompletedCheckpointStore completedCheckpointStore, CheckpointsCleaner checkpointsCleaner, CheckpointIDCounter checkpointIdCounter, org.apache.flink.api.common.time.Time rpcTimeout, BlobWriter blobWriter, org.slf4j.Logger log, ShuffleMaster<?> shuffleMaster, JobMasterPartitionTracker partitionTracker, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint, ExecutionDeploymentListener executionDeploymentListener, ExecutionStateUpdateListener executionStateUpdateListener, long initializationTimestamp, VertexAttemptNumberStore vertexAttemptNumberStore, VertexParallelismStore vertexParallelismStore, java.util.function.Supplier<CheckpointStatsTracker> checkpointStatsTrackerFactory, boolean isDynamicGraph, ExecutionJobVertex.Factory executionJobVertexFactory, MarkPartitionFinishedStrategy markPartitionFinishedStrategy, boolean nonFinishedHybridPartitionShouldBeUnknown, JobManagerJobMetricGroup jobManagerJobMetricGroup)
static Map<IntermediateDataSetID,JobVertexInputInfo>	VertexInputInfoComputationUtils.computeVertexInputInfos(ExecutionJobVertex ejv, java.util.function.Function<IntermediateDataSetID,IntermediateResult> intermediateResultRetriever)
void	ExecutionJobVertex.connectToPredecessors(Map<IntermediateDataSetID,IntermediateResult> intermediateDataSets)
void	Execution.deploy()	Deploys the execution to the previously assigned resource.
void	ExecutionVertex.deploy()
void	ExecutionVertex.deployToSlot(LogicalSlot slot)
protected void	ExecutionJobVertex.initialize(int executionHistorySizeLimit, org.apache.flink.api.common.time.Time timeout, long createTimestamp, SubtaskAttemptNumberStore initialAttemptCounts, CoordinatorStore coordinatorStore, JobManagerJobMetricGroup jobManagerJobMetricGroup)
void	DefaultExecutionGraph.initializeJobVertex(ExecutionJobVertex ejv, long createTimestamp, Map<IntermediateDataSetID,JobVertexInputInfo> jobVertexInputInfos, JobManagerJobMetricGroup jobManagerJobMetricGroup)
void	ExecutionGraph.initializeJobVertex(ExecutionJobVertex ejv, long createTimestamp, Map<IntermediateDataSetID,JobVertexInputInfo> jobVertexInputInfos, JobManagerJobMetricGroup jobManagerJobMetricGroup)	Initialize the given execution job vertex, mainly includes creating execution vertices according to the parallelism, and connecting to the predecessors.
default void	ExecutionGraph.initializeJobVertex(ExecutionJobVertex ejv, long createTimestamp, JobManagerJobMetricGroup jobManagerJobMetricGroup)

Constructors in org.apache.flink.runtime.executiongraph that throw JobException

Constructor	Description
ExecutionJobVertex(InternalExecutionGraphAccessor graph, JobVertex jobVertex, VertexParallelismInformation parallelismInfo)
SpeculativeExecutionJobVertex(InternalExecutionGraphAccessor graph, JobVertex jobVertex, VertexParallelismInformation parallelismInfo)

Uses of JobException in org.apache.flink.runtime.jobmanager.scheduler

Subclasses of JobException in org.apache.flink.runtime.jobmanager.scheduler

Modifier and Type	Class	Description
class	NoResourceAvailableException	Indicates resource allocation failures.

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

Subclasses of JobException in org.apache.flink.runtime.jobmaster

Modifier and Type	Class	Description
class	JobNotFinishedException	Exception indicating that a Flink job has not been finished.

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

Subclasses of JobException in org.apache.flink.runtime.scheduler

Modifier and Type	Class	Description
class	ClusterDatasetCorruptedException	Indicates some task fail to consume cluster dataset.

Methods in org.apache.flink.runtime.scheduler that throw JobException

Modifier and Type	Method	Description
void	DefaultExecutionOperations.deploy(Execution execution)
void	ExecutionOperations.deploy(Execution execution)	Deploy the execution.