public class ApplicationClient extends Object implements FlinkActor, LeaderSessionMessageFilter, LogMessages, LeaderRetrievalListener
This class represents the bridge between the YarnClusterClient
and the
YarnApplicationMasterRunner
.
param: flinkConfig Configuration object
param: leaderRetrievalService LeaderRetrievalService
which is used to retrieve the current
leading JobManager
Constructor and Description |
---|
ApplicationClient(Configuration flinkConfig,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Method and Description |
---|---|
protected static void |
aroundPostRestart(Throwable reason) |
protected static void |
aroundPostStop() |
protected static void |
aroundPreRestart(Throwable reason,
scala.Option<Object> message) |
protected static void |
aroundPreStart() |
protected static void |
aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive,
Object msg) |
static akka.actor.ActorContext |
context() |
static Object |
decorateMessage(Object message) |
void |
disconnectFromJobManager()
Disconnects this
ApplicationClient from the connected YarnJobManager and cancels
the polling timer. |
Configuration |
flinkConfig() |
void |
handleError(Exception exception)
This method is called by the
LeaderRetrievalService in case of an exception. |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
handleMessage()
Handle incoming messages
|
scala.concurrent.duration.FiniteDuration |
INITIAL_POLLING_DELAY() |
static scala.concurrent.duration.FiniteDuration |
INITIAL_REGISTRATION_TIMEOUT() |
boolean |
isConnected()
True if the
ApplicationClient is connected to the YarnJobManager |
LeaderRetrievalService |
leaderRetrievalService() |
scala.Option<UUID> |
leaderSessionID() |
grizzled.slf4j.Logger |
log() |
static scala.concurrent.duration.FiniteDuration |
MAX_REGISTRATION_DURATION() |
static scala.concurrent.duration.FiniteDuration |
MAX_REGISTRATION_TIMEOUT() |
scala.collection.mutable.Queue<InfoMessage> |
messagesQueue() |
void |
notifyLeaderAddress(String leaderAddress,
UUID leaderSessionID)
This method is called by the
LeaderRetrievalService when a new leader is elected. |
scala.concurrent.duration.FiniteDuration |
POLLING_INTERVAL() |
scala.Option<akka.actor.Cancellable> |
pollingTimer() |
static void |
postRestart(Throwable reason) |
void |
postStop() |
static void |
preRestart(Throwable reason,
scala.Option<Object> message) |
void |
preStart() |
static scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
boolean |
running() |
static akka.actor.ActorRef |
self() |
static akka.actor.ActorRef |
sender() |
scala.Option<akka.actor.ActorRef> |
stopMessageReceiver() |
static akka.actor.SupervisorStrategy |
supervisorStrategy() |
void |
unhandled(Object message)
Handle unmatched messages with an exception.
|
scala.concurrent.duration.FiniteDuration |
WAIT_FOR_YARN_INTERVAL() |
scala.Option<akka.actor.ActorRef> |
yarnJobManager() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decorateMessage, handleDiscardedMessage, handleNoLeaderId, receive
receive
public ApplicationClient(Configuration flinkConfig, LeaderRetrievalService leaderRetrievalService)
public static scala.concurrent.duration.FiniteDuration INITIAL_REGISTRATION_TIMEOUT()
public static scala.concurrent.duration.FiniteDuration MAX_REGISTRATION_DURATION()
public static scala.concurrent.duration.FiniteDuration MAX_REGISTRATION_TIMEOUT()
public static akka.actor.ActorContext context()
public static final akka.actor.ActorRef self()
public static final akka.actor.ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive, Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(Throwable reason, scala.Option<Object> message)
protected static void aroundPostRestart(Throwable reason)
public static akka.actor.SupervisorStrategy supervisorStrategy()
public static void preRestart(Throwable reason, scala.Option<Object> message) throws Exception
Exception
public static scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
public Configuration flinkConfig()
public LeaderRetrievalService leaderRetrievalService()
public grizzled.slf4j.Logger log()
log
in interface FlinkActor
public scala.concurrent.duration.FiniteDuration INITIAL_POLLING_DELAY()
public scala.concurrent.duration.FiniteDuration WAIT_FOR_YARN_INTERVAL()
public scala.concurrent.duration.FiniteDuration POLLING_INTERVAL()
public scala.Option<akka.actor.ActorRef> yarnJobManager()
public scala.Option<akka.actor.Cancellable> pollingTimer()
public boolean running()
public scala.collection.mutable.Queue<InfoMessage> messagesQueue()
public scala.Option<akka.actor.ActorRef> stopMessageReceiver()
public scala.Option<UUID> leaderSessionID()
leaderSessionID
in interface LeaderSessionMessageFilter
public void preStart()
preStart
in interface akka.actor.Actor
public void postStop()
postStop
in interface akka.actor.Actor
public scala.PartialFunction<Object,scala.runtime.BoxedUnit> handleMessage()
FlinkActor
handleMessage
in interface FlinkActor
public void disconnectFromJobManager()
ApplicationClient
from the connected YarnJobManager
and cancels
the polling timer.
public boolean isConnected()
ApplicationClient
is connected to the YarnJobManager
public void unhandled(Object message)
unhandled
in interface akka.actor.Actor
message
- (undocumented)public void notifyLeaderAddress(String leaderAddress, UUID leaderSessionID)
LeaderRetrievalListener
LeaderRetrievalService
when a new leader is elected.notifyLeaderAddress
in interface LeaderRetrievalListener
leaderAddress
- The address of the new leaderleaderSessionID
- The new leader session IDpublic void handleError(Exception exception)
LeaderRetrievalListener
LeaderRetrievalService
in case of an exception. This
assures that the LeaderRetrievalListener
is aware of any problems occurring in the
LeaderRetrievalService
thread.handleError
in interface LeaderRetrievalListener
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.