public class TestingResourceManager extends StandaloneResourceManager
Modifier and Type | Class and Description |
---|---|
static class |
TestingResourceManager.FailResource
Fails all resources that the resource manager has registered
|
static class |
TestingResourceManager.GetRegisteredResources
Testing messages
|
static class |
TestingResourceManager.GetRegisteredResourcesReply |
static class |
TestingResourceManager.NotifyWhenResourceManagerConnected
The sender of this message will be informed of a connection to the Job Manager
|
config, EXIT_CODE_FATAL_ERROR, RESOURCE_MANAGER_NAME
LOG
Constructor and Description |
---|
TestingResourceManager(Configuration flinkConfig,
LeaderRetrievalService leaderRetriever) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleMessage(Object message)
Overwrite messages here if desired
|
protected void |
shutdownApplication(ApplicationStatus finalStatus,
String optionalDiagnostics)
Inform registered listeners about a shutdown of the application.
|
fatalError, getNumWorkerRequestsPending, getNumWorkersPendingRegistration, initialize, reacceptRegisteredWorkers, releasePendingWorker, releaseStartedWorker, requestNewWorkers, triggerConnectingToJobManager, workerStarted
allStartedWorkers, getDesignatedWorkerPoolSize, getLeaderSessionID, getNumberOfStartedTaskManagers, getStartedTaskManagers, isStarted, notifyWorkerFailed, postStop, preStart, sendInfoMessage, startResourceManagerActors, startResourceManagerActors, triggerCheckWorkers
decorateMessage, onReceive
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled
public TestingResourceManager(Configuration flinkConfig, LeaderRetrievalService leaderRetriever)
protected void handleMessage(Object message)
handleMessage
in class StandaloneResourceManager
message
- The incoming actor message.protected void shutdownApplication(ApplicationStatus finalStatus, String optionalDiagnostics)
shutdownApplication
in class StandaloneResourceManager
finalStatus
- The application status to report.optionalDiagnostics
- An optional diagnostics message.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.