org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionDriver

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriver

All Implemented Interfaces:

AutoCloseable, LeaderElectionDriver

Deprecated.

in favour of KubernetesMultipleComponentLeaderElectionDriver

@Deprecated
public class KubernetesLeaderElectionDriver
extends Object
implements LeaderElectionDriver

LeaderElectionDriver implementation for Kubernetes. The active leader is elected using Kubernetes. The current leader's address as well as its leader session ID is published via Kubernetes ConfigMap. Note that the contending lock and leader storage are using the same ConfigMap. And every component(e.g. ResourceManager, Dispatcher, RestEndpoint, JobManager for each job) will have a separate ConfigMap.

Constructor Summary

Constructors

Constructor and Description
KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient, KubernetesConfigMapSharedWatcher configMapSharedWatcher, ExecutorService watchExecutorService, KubernetesLeaderElectionConfiguration leaderConfig, LeaderElectionEventHandler leaderElectionEventHandler, FatalErrorHandler fatalErrorHandler) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated.
boolean	hasLeadership() Deprecated. Check whether the driver still have the leadership in the distributed coordination system.
String	toString() Deprecated.
void	writeLeaderInformation(LeaderInformation leaderInformation) Deprecated. Write the current leader information to external persistent storage(e.g.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLeaderElectionDriver

public KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient,
                                      KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                      ExecutorService watchExecutorService,
                                      KubernetesLeaderElectionConfiguration leaderConfig,
                                      LeaderElectionEventHandler leaderElectionEventHandler,
                                      FatalErrorHandler fatalErrorHandler)

Deprecated.

Method Detail

close

public void close()

Deprecated.

Specified by:

close in interface AutoCloseable

writeLeaderInformation

public void writeLeaderInformation(LeaderInformation leaderInformation)

Deprecated.

Description copied from interface: LeaderElectionDriver

Write the current leader information to external persistent storage(e.g. Zookeeper, Kubernetes ConfigMap). This is a blocking IO operation. The write operation takes effect only when the driver still has the leadership.

Specified by:

writeLeaderInformation in interface LeaderElectionDriver

Parameters:

leaderInformation - current leader information. It could be LeaderInformation.empty(), which means the caller want to clear the leader information on external storage. Please remember that the clear operation should only happen before a new leader is elected and has written his leader information on the storage. Otherwise, we may have a risk to wrongly update the storage with empty leader information.

hasLeadership

public boolean hasLeadership()

Deprecated.

Description copied from interface: LeaderElectionDriver

Check whether the driver still have the leadership in the distributed coordination system.

Specified by:

hasLeadership in interface LeaderElectionDriver

Returns:

Return whether the driver has leadership.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object