org.apache.flink.runtime.jobmanager

Interface JobGraphStore.JobGraphListener

All Known Implementing Classes:

DefaultJobGraphStore, SessionDispatcherLeaderProcess

Enclosing interface:

JobGraphStore

public static interface JobGraphStore.JobGraphListener

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

Method Summary

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

Method Detail

onAddedJobGraph

void onAddedJobGraph(JobID jobId)

Callback for JobGraph instances added by a different JobGraphStore 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 JobGraph instances removed by a different JobGraphStore instance.

Parameters:

jobId - The JobID of the removed job graph