org.apache.flink.runtime.jobmanager

Interface SubmittedJobGraphStore.SubmittedJobGraphListener

All Known Implementing Classes:

JobManager, YarnJobManager

Enclosing interface:

SubmittedJobGraphStore

public static interface SubmittedJobGraphStore.SubmittedJobGraphListener

A listener for SubmittedJobGraph instances. This is used to react to races between multiple running SubmittedJobGraphStore instances (on multiple job managers).

Method Summary

Modifier and Type	Method and Description
void	onAddedJobGraph(JobID jobId) Callback for SubmittedJobGraph instances added by a different SubmittedJobGraphStore instance.
void	onRemovedJobGraph(JobID jobId) Callback for SubmittedJobGraph instances removed by a different SubmittedJobGraphStore instance.

Method Detail

onAddedJobGraph

void onAddedJobGraph(JobID jobId)

Callback for SubmittedJobGraph instances added by a different SubmittedJobGraphStore instance.

Important: It is possible to get false positives and be notified about a job graph, which was added by this instance.

Parameters:

jobId - The JobID of the added job graph

onRemovedJobGraph

void onRemovedJobGraph(JobID jobId)

Callback for SubmittedJobGraph instances removed by a different SubmittedJobGraphStore instance.

Parameters:

jobId - The JobID of the removed job graph