public class ResourceManagerRunner extends Object implements FatalErrorHandler, AutoCloseableAsync
StandaloneResourceManager
runner. It instantiates the resource manager's services
and handles fatal errors by shutting the resource manager down.Constructor and Description |
---|
ResourceManagerRunner(ResourceID resourceId,
String resourceManagerEndpointId,
Configuration configuration,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
ClusterInformation clusterInformation,
JobManagerMetricGroup jobManagerMetricGroup) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
closeAsync()
Trigger the closing of the resource and return the corresponding
close future.
|
ResourceManagerGateway |
getResourceManageGateway() |
void |
onFatalError(Throwable exception)
Being called when a fatal error occurs.
|
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public ResourceManagerRunner(ResourceID resourceId, String resourceManagerEndpointId, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, ClusterInformation clusterInformation, JobManagerMetricGroup jobManagerMetricGroup) throws Exception
Exception
public ResourceManagerGateway getResourceManageGateway()
public CompletableFuture<Void> closeAsync()
AutoCloseableAsync
closeAsync
in interface AutoCloseableAsync
public void onFatalError(Throwable exception)
FatalErrorHandler
IMPORTANT: This call should never be blocking since it might be called from within
the main thread of an RpcEndpoint
.
onFatalError
in interface FatalErrorHandler
exception
- causeCopyright © 2014–2019 The Apache Software Foundation. All rights reserved.