org.apache.flink.core.execution

Interface JobStatusHook

All Superinterfaces:

Serializable

All Known Implementing Classes:

StagingSinkJobStatusHook

@Internal
public interface JobStatusHook
extends Serializable

Hooks on job status changing. Triggered at the initial(CREATED) and final state(FINISHED/CANCELED/FAILED) of the job.

Usage examples:

     StreamGraph streamGraph = env.getStreamGraph();
     streamGraph.registerJobStatusHook(myJobStatusHook);
     streamGraph.setJobName("my_flink");
     env.execute(streamGraph);
 

Method Summary

Modifier and Type	Method and Description
void	onCanceled(JobID jobId) When job get canceled by users.
void	onCreated(JobID jobId) When Job becomes JobStatus.CREATED status, it would only be called one time.
void	onFailed(JobID jobId, Throwable throwable) When job failed finally.
void	onFinished(JobID jobId) When job finished successfully.

Method Detail

onCreated

void onCreated(JobID jobId)

When Job becomes JobStatus.CREATED status, it would only be called one time.

onFinished

void onFinished(JobID jobId)

When job finished successfully.

onFailed

void onFailed(JobID jobId,
              Throwable throwable)

When job failed finally.

onCanceled

void onCanceled(JobID jobId)

When job get canceled by users.