public class KubernetesLeaderRetrievalDriver extends Object implements LeaderRetrievalDriver
KubernetesLeaderElectionDriver
. LeaderRetrievalDriver
implementation for Kubernetes. It retrieves the current leader which has been elected by the
KubernetesLeaderElectionDriver
. The leader address as well as the current leader session
ID is retrieved from Kubernetes ConfigMap.Constructor and Description |
---|
KubernetesLeaderRetrievalDriver(FlinkKubeClient kubeClient,
String configMapName,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the services used for leader retrieval.
|
String |
toString() |
public KubernetesLeaderRetrievalDriver(FlinkKubeClient kubeClient, String configMapName, LeaderRetrievalEventHandler leaderRetrievalEventHandler, FatalErrorHandler fatalErrorHandler)
public void close()
LeaderRetrievalDriver
close
in interface LeaderRetrievalDriver
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.