org.apache.flink.runtime.jobmanager

Interface OnCompletionActions

All Known Implementing Classes:

DefaultJobMasterServiceProcess

public interface OnCompletionActions

Interface for completion actions once a Flink job has reached a terminal state.

Method Summary

Modifier and Type	Method and Description
void	jobMasterFailed(Throwable cause) The JobMaster failed while executing the job.
void	jobReachedGloballyTerminalState(ExecutionGraphInfo executionGraphInfo) Job reached a globally terminal state.

Method Detail

jobReachedGloballyTerminalState

void jobReachedGloballyTerminalState(ExecutionGraphInfo executionGraphInfo)

Job reached a globally terminal state.

Parameters:

executionGraphInfo - contains information about the terminated job

jobMasterFailed

void jobMasterFailed(Throwable cause)

The JobMaster failed while executing the job.