Package org.apache.flink.kubernetes.operator.observer

Class JobStatusObserver<R extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>

java.lang.Object

org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R>

public abstract class JobStatusObserver<R extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>
extends java.lang.Object

An observer to observe the job status.

Field Summary

Fields

Modifier and Type	Field	Description
protected EventRecorder	eventRecorder
static java.lang.String	MISSING_SESSION_JOB_ERR

Constructor Summary

Constructors

Constructor	Description
JobStatusObserver(EventRecorder eventRecorder)

Method Summary

Modifier and Type	Method	Description
protected abstract java.util.Optional<org.apache.flink.runtime.client.JobStatusMessage>	filterTargetJob(org.apache.flink.kubernetes.operator.api.status.JobStatus status, java.util.List<org.apache.flink.runtime.client.JobStatusMessage> clusterJobStatuses)	Filter the target job status message by the job list from the cluster.
boolean	observe(FlinkResourceContext<R> ctx)	Observe the status of the flink job.
protected void	onNoJobsFound(FlinkResourceContext<R> ctx)	Callback when no jobs were found on the cluster.
protected abstract void	onTargetJobNotFound(FlinkResourceContext<R> ctx)	Callback when no matching target job was found on a cluster where jobs were found.
protected abstract void	onTimeout(FlinkResourceContext<R> ctx)	Callback when list jobs timeout.

Methods inherited from class java.lang.Object

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

Field Detail

MISSING_SESSION_JOB_ERR

public static final java.lang.String MISSING_SESSION_JOB_ERR

See Also:

Constant Field Values

eventRecorder

protected final EventRecorder eventRecorder

Constructor Detail

JobStatusObserver

public JobStatusObserver(EventRecorder eventRecorder)

Method Detail

observe

public boolean observe(FlinkResourceContext<R> ctx)

Observe the status of the flink job.

Parameters:

ctx - Resource context.

Returns:

If job found return true, otherwise return false.

onTargetJobNotFound

protected abstract void onTargetJobNotFound(FlinkResourceContext<R> ctx)

Callback when no matching target job was found on a cluster where jobs were found.

Parameters:

ctx - The Flink resource context.

onNoJobsFound

protected void onNoJobsFound(FlinkResourceContext<R> ctx)

Callback when no jobs were found on the cluster.

Parameters:

ctx - The Flink resource context.

onTimeout

protected abstract void onTimeout(FlinkResourceContext<R> ctx)

Callback when list jobs timeout.

Parameters:

ctx - Resource context.

filterTargetJob

protected abstract java.util.Optional<org.apache.flink.runtime.client.JobStatusMessage> filterTargetJob(org.apache.flink.kubernetes.operator.api.status.JobStatus status,
                                                                                                        java.util.List<org.apache.flink.runtime.client.JobStatusMessage> clusterJobStatuses)

Filter the target job status message by the job list from the cluster.

Parameters:

status - the target job status.

clusterJobStatuses - the candidate cluster jobs.

Returns:

The target job status message. If no matched job found, Optional.empty() will be returned.