org.apache.hadoop.yarn.server.resourcemanager

Class ClientRMService

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.yarn.server.resourcemanager.ClientRMService

All Implemented Interfaces:

Closeable, AutoCloseable, Service, ApplicationClientProtocol

public class ClientRMService
extends AbstractService
implements ApplicationClientProtocol

The client interface to the Resource Manager. This module handles all the rpc interfaces to the resource manager from the client.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
protected RMDelegationTokenSecretManager	rmDTSecretManager

Constructor Summary

Constructors

Constructor and Description
ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager)

Method Summary

Methods

Modifier and Type	Method and Description
CancelDelegationTokenResponse	cancelDelegationToken(CancelDelegationTokenRequest request) Cancel an existing delegation Token.
KillApplicationResponse	forceKillApplication(KillApplicationRequest request) The interface used by clients to request the ResourceManager to abort submitted application.
GetApplicationReportResponse	getApplicationReport(GetApplicationReportRequest request) It gives response which includes application report if the application present otherwise throws ApplicationNotFoundException.
GetApplicationsResponse	getApplications(GetApplicationsRequest request) The interface used by clients to get a report of Applications matching the filters defined by GetApplicationsRequest in the cluster from the ResourceManager.
InetSocketAddress	getBindAddress()
GetClusterMetricsResponse	getClusterMetrics(GetClusterMetricsRequest request) The interface used by clients to get metrics about the cluster from the ResourceManager.
GetClusterNodesResponse	getClusterNodes(GetClusterNodesRequest request) The interface used by clients to get a report of all nodes in the cluster from the ResourceManager.
GetDelegationTokenResponse	getDelegationToken(GetDelegationTokenRequest request) The interface used by clients to get delegation token, enabling the containers to be able to talk to the service using those tokens.
GetNewApplicationResponse	getNewApplication(GetNewApplicationRequest request) The interface used by clients to obtain a new ApplicationId for submitting new applications.
GetQueueInfoResponse	getQueueInfo(GetQueueInfoRequest request) The interface used by clients to get information about queues from the ResourceManager.
GetQueueUserAclsInfoResponse	getQueueUserAcls(GetQueueUserAclsInfoRequest request) The interface used by clients to get information about queue acls for current user from the ResourceManager.
RenewDelegationTokenResponse	renewDelegationToken(RenewDelegationTokenRequest request) Renew an existing delegation Token.
protected void	serviceInit(Configuration conf) All initialization code needed by a service.
protected void	serviceStart() Actions called during the INITED to STARTED transition.
protected void	serviceStop() Actions called during the transition to the STOPPED state.
SubmitApplicationResponse	submitApplication(SubmitApplicationRequest request) The interface used by clients to submit a new application to the ResourceManager.

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Field Detail

rmDTSecretManager

protected RMDelegationTokenSecretManager rmDTSecretManager

Constructor Detail

ClientRMService

public ClientRMService(RMContext rmContext,
               YarnScheduler scheduler,
               RMAppManager rmAppManager,
               ApplicationACLsManager applicationACLsManager,
               QueueACLsManager queueACLsManager,
               RMDelegationTokenSecretManager rmDTSecretManager)

Method Detail

serviceInit

protected void serviceInit(Configuration conf)
                    throws Exception

Description copied from class: AbstractService

All initialization code needed by a service. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.init(Configuration) prevents re-entrancy. The base implementation checks to see if the subclass has created a new configuration instance, and if so, updates the base class value

Overrides:

serviceInit in class AbstractService

Parameters:

conf - configuration

Throws:

Exception - on a failure -these will be caught, possibly wrapped, and wil; trigger a service stop

serviceStart

protected void serviceStart()
                     throws Exception

Description copied from class: AbstractService

Actions called during the INITED to STARTED transition. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.start() prevents re-entrancy.

Overrides:

serviceStart in class AbstractService

Throws:

Exception - if needed -these will be caught, wrapped, and trigger a service stop

serviceStop

protected void serviceStop()
                    throws Exception

Description copied from class: AbstractService

Actions called during the transition to the STOPPED state. This method will only ever be called once during the lifecycle of a specific service instance. Implementations do not need to be synchronized as the logic in AbstractService.stop() prevents re-entrancy. Implementations MUST write this to be robust against failures, including checks for null references -and for the first failure to not stop other attempts to shut down parts of the service.

Overrides:

serviceStop in class AbstractService

Throws:

Exception - if needed -these will be caught and logged.

getBindAddress

@InterfaceAudience.Private
public InetSocketAddress getBindAddress()

getNewApplication

public GetNewApplicationResponse getNewApplication(GetNewApplicationRequest request)
                                            throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to obtain a new ApplicationId for submitting new applications.

The ResourceManager responds with a new, monotonically increasing, ApplicationId which is used by the client to submit a new application.

The ResourceManager also responds with details such as maximum resource capabilities in the cluster as specified in GetNewApplicationResponse.

Specified by:

getNewApplication in interface ApplicationClientProtocol

Parameters:

request - request to get a new ApplicationId

Returns:

response containing the new ApplicationId to be used to submit an application

Throws:

YarnException

See Also:

ApplicationClientProtocol.submitApplication(SubmitApplicationRequest)

getApplicationReport

public GetApplicationReportResponse getApplicationReport(GetApplicationReportRequest request)
                                                  throws YarnException

It gives response which includes application report if the application present otherwise throws ApplicationNotFoundException.

Specified by:

getApplicationReport in interface ApplicationClientProtocol

Parameters:

request - request for an application report

Returns:

application report

Throws:

YarnException

submitApplication

public SubmitApplicationResponse submitApplication(SubmitApplicationRequest request)
                                            throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to submit a new application to the ResourceManager.

The client is required to provide details such as queue, Resource required to run the ApplicationMaster, the equivalent of ContainerLaunchContext for launching the ApplicationMaster etc. via the SubmitApplicationRequest.

Currently the ResourceManager sends an immediate (empty) SubmitApplicationResponse on accepting the submission and throws an exception if it rejects the submission. However, this call needs to be followed by ApplicationClientProtocol.getApplicationReport(GetApplicationReportRequest) to make sure that the application gets properly submitted.

In secure mode,the ResourceManager verifies access to queues etc. before accepting the application submission.

Specified by:

submitApplication in interface ApplicationClientProtocol

Parameters:

request - request to submit a new application

Returns:

(empty) response on accepting the submission

Throws:

YarnException

See Also:

ApplicationClientProtocol.getNewApplication(GetNewApplicationRequest)

forceKillApplication

public KillApplicationResponse forceKillApplication(KillApplicationRequest request)
                                             throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to request the ResourceManager to abort submitted application.

The client, via KillApplicationRequest provides the ApplicationId of the application to be aborted.

In secure mode,the ResourceManager verifies access to the application, queue etc. before terminating the application.

Currently, the ResourceManager returns an empty response on success and throws an exception on rejecting the request.

Specified by:

forceKillApplication in interface ApplicationClientProtocol

Parameters:

request - request to abort a submitted application

Returns:

ResourceManager returns an empty response on success and throws an exception on rejecting the request

Throws:

YarnException

See Also:

ApplicationClientProtocol.getQueueUserAcls(GetQueueUserAclsInfoRequest)

getClusterMetrics

public GetClusterMetricsResponse getClusterMetrics(GetClusterMetricsRequest request)
                                            throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get metrics about the cluster from the ResourceManager.

The ResourceManager responds with a GetClusterMetricsResponse which includes the YarnClusterMetrics with details such as number of current nodes in the cluster.

Specified by:

getClusterMetrics in interface ApplicationClientProtocol

Parameters:

request - request for cluster metrics

Returns:

cluster metrics

Throws:

YarnException

getApplications

public GetApplicationsResponse getApplications(GetApplicationsRequest request)
                                        throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get a report of Applications matching the filters defined by GetApplicationsRequest in the cluster from the ResourceManager.

The ResourceManager responds with a GetApplicationsResponse which includes the ApplicationReport for the applications.

If the user does not have VIEW_APP access for an application then the corresponding report will be filtered as described in ApplicationClientProtocol.getApplicationReport(GetApplicationReportRequest).

Specified by:

getApplications in interface ApplicationClientProtocol

Parameters:

request - request for report on applications

Returns:

report on applications matching the given application types defined in the request

Throws:

YarnException

See Also:

GetApplicationsRequest

getClusterNodes

public GetClusterNodesResponse getClusterNodes(GetClusterNodesRequest request)
                                        throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get a report of all nodes in the cluster from the ResourceManager.

The ResourceManager responds with a GetClusterNodesResponse which includes the NodeReport for all the nodes in the cluster.

Specified by:

getClusterNodes in interface ApplicationClientProtocol

Parameters:

request - request for report on all nodes

Returns:

report on all nodes

Throws:

YarnException

getQueueInfo

public GetQueueInfoResponse getQueueInfo(GetQueueInfoRequest request)
                                  throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get information about queues from the ResourceManager.

The client, via GetQueueInfoRequest, can ask for details such as used/total resources, child queues, running applications etc.

In secure mode,the ResourceManager verifies access before providing the information.

Specified by:

getQueueInfo in interface ApplicationClientProtocol

Parameters:

request - request to get queue information

Returns:

queue information

Throws:

YarnException

getQueueUserAcls

public GetQueueUserAclsInfoResponse getQueueUserAcls(GetQueueUserAclsInfoRequest request)
                                              throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get information about queue acls for current user from the ResourceManager.

The ResourceManager responds with queue acls for all existing queues.

Specified by:

getQueueUserAcls in interface ApplicationClientProtocol

Parameters:

request - request to get queue acls for current user

Returns:

queue acls for current user

Throws:

YarnException

getDelegationToken

public GetDelegationTokenResponse getDelegationToken(GetDelegationTokenRequest request)
                                              throws YarnException

Description copied from interface: ApplicationClientProtocol

The interface used by clients to get delegation token, enabling the containers to be able to talk to the service using those tokens.

The ResourceManager responds with the delegation Token that can be used by the client to speak to this service.

Specified by:

getDelegationToken in interface ApplicationClientProtocol

Parameters:

request - request to get a delegation token for the client.

Returns:

delegation token that can be used to talk to this service

Throws:

YarnException

renewDelegationToken

public RenewDelegationTokenResponse renewDelegationToken(RenewDelegationTokenRequest request)
                                                  throws YarnException

Description copied from interface: ApplicationClientProtocol

Renew an existing delegation Token.

Specified by:

renewDelegationToken in interface ApplicationClientProtocol

Parameters:

request - the delegation token to be renewed.

Returns:

the new expiry time for the delegation token.

Throws:

YarnException

cancelDelegationToken

public CancelDelegationTokenResponse cancelDelegationToken(CancelDelegationTokenRequest request)
                                                    throws YarnException

Description copied from interface: ApplicationClientProtocol

Cancel an existing delegation Token.

Specified by:

cancelDelegationToken in interface ApplicationClientProtocol

Parameters:

request - the delegation token to be cancelled.

Returns:

an empty response.

Throws:

YarnException