org.apache.flink.runtime.scheduler.adaptive

Class CreatingExecutionGraph

java.lang.Object

org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph

public class CreatingExecutionGraph
extends Object

State which waits for the creation of the ExecutionGraph. If the creation fails, then the state transitions to Finished. If the creation succeeds, then the system tries to assign the required slots. If the set of available slots has changed so that the created ExecutionGraph cannot be executed, the state transitions back into WaitingForResources. If there are enough slots for the ExecutionGraph to run, the state transitions to Executing.

Constructor Summary

Constructors

Constructor and Description

CreatingExecutionGraph(org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.Context context, CompletableFuture<org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.ExecutionGraphWithVertexParallelism> executionGraphWithParallelismFuture, org.slf4j.Logger logger, org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.OperatorCoordinatorHandlerFactory operatorCoordinatorFactory)

Method Summary

Modifier and Type	Method and Description
default <T> Optional<T>	as(Class<? extends T> clazz) Tries to cast this state into a type of the given clazz.
void	cancel() Cancels the job execution.
ArchivedExecutionGraph	getJob() Gets the current ArchivedExecutionGraph.
JobStatus	getJobStatus() Gets the current JobStatus.
org.slf4j.Logger	getLogger() Gets the logger.
void	handleGlobalFailure(Throwable cause) Handles a global failure.
default void	onLeave(Class<? extends org.apache.flink.runtime.scheduler.adaptive.State> newState) This method is called whenever one transitions out of this state.
void	suspend(Throwable cause) Suspends the job execution.
default <T,V,E extends Exception> Optional<V>	tryCall(Class<? extends T> clazz, FunctionWithException<T,V,E> action, String debugMessage) Tries to run the action if this state is of type clazz.
default <T,E extends Exception> void	tryRun(Class<? extends T> clazz, ThrowingConsumer<T,E> action, String debugMessage) Tries to run the action if this state is of type clazz.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreatingExecutionGraph

public CreatingExecutionGraph(org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.Context context,
                              CompletableFuture<org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.ExecutionGraphWithVertexParallelism> executionGraphWithParallelismFuture,
                              org.slf4j.Logger logger,
                              org.apache.flink.runtime.scheduler.adaptive.CreatingExecutionGraph.OperatorCoordinatorHandlerFactory operatorCoordinatorFactory)

Method Detail

cancel

public void cancel()

Cancels the job execution.

suspend

public void suspend(Throwable cause)

Suspends the job execution.

Parameters:

cause - cause for the suspension

getJobStatus

public JobStatus getJobStatus()

Gets the current JobStatus. The returned job status will remain unchanged at least until the scheduler transitions to a different state.

Returns:

the current JobStatus

getJob

public ArchivedExecutionGraph getJob()

Gets the current ArchivedExecutionGraph.

Returns:

the current ArchivedExecutionGraph

handleGlobalFailure

public void handleGlobalFailure(Throwable cause)

Description copied from interface: GlobalFailureHandler

Handles a global failure.

Parameters:

cause - A cause that describes the global failure.

getLogger

public org.slf4j.Logger getLogger()

Gets the logger.

Returns:

the logger

onLeave

public void onLeave(Class<? extends org.apache.flink.runtime.scheduler.adaptive.State> newState)

This method is called whenever one transitions out of this state.

Parameters:

newState - newState is the state into which the scheduler transitions

as

public <T> Optional<T> as(Class<? extends T> clazz)

Tries to cast this state into a type of the given clazz.

Type Parameters:

T - target type

Parameters:

clazz - clazz describes the target type

Returns:

Optional.of(T) target type if the underlying type can be cast into clazz; otherwise Optional.empty()

tryRun

public <T,E extends Exception> void tryRun(Class<? extends T> clazz,
                                           ThrowingConsumer<T,E> action,
                                           String debugMessage)
                                    throws E extends Exception

Tries to run the action if this state is of type clazz.

Type Parameters:

T - target type

E - error type

Parameters:

clazz - clazz describes the target type

action - action to run if this state is of the target type

debugMessage - debugMessage which is printed if this state is not the target type

Throws:

E - an exception if the action fails

E extends Exception

tryCall

public <T,V,E extends Exception> Optional<V> tryCall(Class<? extends T> clazz,
                                                     FunctionWithException<T,V,E> action,
                                                     String debugMessage)
                                              throws E extends Exception

Tries to run the action if this state is of type clazz.

Type Parameters:

T - target type

V - value type

E - error type

Parameters:

clazz - clazz describes the target type

action - action to run if this state is of the target type

debugMessage - debugMessage which is printed if this state is not the target type

Returns:

Optional.of(T) the action result if it is successfully executed; otherwise Optional.empty()

Throws:

E - an exception if the action fails

E extends Exception