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, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.api.ApplicationBaseProtocol, org.apache.hadoop.yarn.api.ApplicationClientProtocol

public class ClientRMService
extends org.apache.hadoop.service.AbstractService
implements org.apache.hadoop.yarn.api.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

org.apache.hadoop.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, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager)
ClientRMService(RMContext rmContext, YarnScheduler scheduler, RMAppManager rmAppManager, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, QueueACLsManager queueACLsManager, RMDelegationTokenSecretManager rmDTSecretManager, org.apache.hadoop.yarn.util.Clock clock)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse	cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request)
org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse	deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request)
org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptResponse	failApplicationAttempt(org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptRequest request)
org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse	forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse	getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse	getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse	getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request) It gives response which includes application report if the application present otherwise throws ApplicationNotFoundException.
org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse	getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request) Get applications matching the GetApplicationsRequest.
InetSocketAddress	getBindAddress()
org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse	getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse	getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse	getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse	getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse	getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse	getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse	getLabelsToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse	getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse	getNewReservation(org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse	getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse	getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse	getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse	getResourceProfile(org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse	getResourceProfiles(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesRequest request)
org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse	getResourceTypeInfo(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoRequest request)
org.apache.hadoop.ipc.Server	getServer()
org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse	listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest requestInfo)
org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse	moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request)
org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse	renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request)
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()
void	setDisplayPerUserApps(boolean displayPerUserApps)
org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse	signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request) Send a signal to a container.
org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse	submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request)
org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse	submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request)
org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityResponse	updateApplicationPriority(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityRequest request)
org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsResponse	updateApplicationTimeouts(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsRequest request)
org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse	updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request)

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,
                       org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
                       QueueACLsManager queueACLsManager,
                       RMDelegationTokenSecretManager rmDTSecretManager)

ClientRMService

public ClientRMService(RMContext rmContext,
                       YarnScheduler scheduler,
                       RMAppManager rmAppManager,
                       org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
                       QueueACLsManager queueACLsManager,
                       RMDelegationTokenSecretManager rmDTSecretManager,
                       org.apache.hadoop.yarn.util.Clock clock)

Method Detail

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

Throws:

Exception

getBindAddress

@InterfaceAudience.Private
public InetSocketAddress getBindAddress()

getNewApplication

public org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse getNewApplication(org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getNewApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getApplicationReport

public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse getApplicationReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest request)
                                                                                             throws org.apache.hadoop.yarn.exceptions.YarnException

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

Specified by:

getApplicationReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getApplicationAttemptReport

public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportResponse getApplicationAttemptReport(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptReportRequest request)
                                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                                  IOException

Specified by:

getApplicationAttemptReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getApplicationAttempts

public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsResponse getApplicationAttempts(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationAttemptsRequest request)
                                                                                                 throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                        IOException

Specified by:

getApplicationAttempts in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getContainerReport

public org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportResponse getContainerReport(org.apache.hadoop.yarn.api.protocolrecords.GetContainerReportRequest request)
                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                IOException

Specified by:

getContainerReport in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getContainers

public org.apache.hadoop.yarn.api.protocolrecords.GetContainersResponse getContainers(org.apache.hadoop.yarn.api.protocolrecords.GetContainersRequest request)
                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                      IOException

Specified by:

getContainers in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

submitApplication

public org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationResponse submitApplication(org.apache.hadoop.yarn.api.protocolrecords.SubmitApplicationRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                              IOException

Specified by:

submitApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

failApplicationAttempt

public org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptResponse failApplicationAttempt(org.apache.hadoop.yarn.api.protocolrecords.FailApplicationAttemptRequest request)
                                                                                                 throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

failApplicationAttempt in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

forceKillApplication

public org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse forceKillApplication(org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest request)
                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

forceKillApplication in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getClusterMetrics

public org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse getClusterMetrics(org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getClusterMetrics in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getApplications

public org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsResponse getApplications(org.apache.hadoop.yarn.api.protocolrecords.GetApplicationsRequest request)
                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException

Get applications matching the GetApplicationsRequest. If caseSensitive is set to false, applicationTypes in GetApplicationRequest are expected to be in all-lowercase

Specified by:

getApplications in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getClusterNodes

public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse getClusterNodes(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest request)
                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getClusterNodes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getQueueInfo

public org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse getQueueInfo(org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest request)
                                                                             throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getQueueInfo in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getQueueUserAcls

public org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse getQueueUserAcls(org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest request)
                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getQueueUserAcls in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getDelegationToken

public org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenResponse getDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest request)
                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

getDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

renewDelegationToken

public org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenResponse renewDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.RenewDelegationTokenRequest request)
                                                                                             throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

renewDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

cancelDelegationToken

public org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse cancelDelegationToken(org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest request)
                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

cancelDelegationToken in interface org.apache.hadoop.yarn.api.ApplicationBaseProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

moveApplicationAcrossQueues

public org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesResponse moveApplicationAcrossQueues(org.apache.hadoop.yarn.api.protocolrecords.MoveApplicationAcrossQueuesRequest request)
                                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

moveApplicationAcrossQueues in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

getServer

public org.apache.hadoop.ipc.Server getServer()

getNewReservation

public org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationResponse getNewReservation(org.apache.hadoop.yarn.api.protocolrecords.GetNewReservationRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                              IOException

Specified by:

getNewReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

submitReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionResponse submitReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationSubmissionRequest request)
                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                  IOException

Specified by:

submitReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateResponse updateReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationUpdateRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                              IOException

Specified by:

updateReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteReservation

public org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteResponse deleteReservation(org.apache.hadoop.yarn.api.protocolrecords.ReservationDeleteRequest request)
                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                              IOException

Specified by:

deleteReservation in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

listReservations

public org.apache.hadoop.yarn.api.protocolrecords.ReservationListResponse listReservations(org.apache.hadoop.yarn.api.protocolrecords.ReservationListRequest requestInfo)
                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                           IOException

Specified by:

listReservations in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getNodeToLabels

public org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponse getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request)
                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                           IOException

Specified by:

getNodeToLabels in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getLabelsToNodes

public org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponse getLabelsToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesRequest request)
                                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                            IOException

Specified by:

getLabelsToNodes in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getClusterNodeLabels

public org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsResponse getClusterNodeLabels(org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodeLabelsRequest request)
                                                                                             throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                    IOException

Specified by:

getClusterNodeLabels in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

updateApplicationPriority

public org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityResponse updateApplicationPriority(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationPriorityRequest request)
                                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                              IOException

Specified by:

updateApplicationPriority in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

signalToContainer

public org.apache.hadoop.yarn.api.protocolrecords.SignalContainerResponse signalToContainer(org.apache.hadoop.yarn.api.protocolrecords.SignalContainerRequest request)
                                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                            IOException

Send a signal to a container. After the request passes some sanity check, it will be delivered to RMNodeImpl so that the next NM heartbeat will pick up the signal request

Specified by:

signalToContainer in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Parameters:

request - request to signal a container

Returns:

the response of sending signal request

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - rpc related exception

IOException - fail to obtain user group information

updateApplicationTimeouts

public org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsResponse updateApplicationTimeouts(org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsRequest request)
                                                                                                       throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                              IOException

Specified by:

updateApplicationTimeouts in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceProfiles

public org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesResponse getResourceProfiles(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceProfilesRequest request)
                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                     IOException

Specified by:

getResourceProfiles in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceProfile

public org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileResponse getResourceProfile(org.apache.hadoop.yarn.api.protocolrecords.GetResourceProfileRequest request)
                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                IOException

Specified by:

getResourceProfile in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getResourceTypeInfo

public org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoResponse getResourceTypeInfo(org.apache.hadoop.yarn.api.protocolrecords.GetAllResourceTypeInfoRequest request)
                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
                                                                                                     IOException

Specified by:

getResourceTypeInfo in interface org.apache.hadoop.yarn.api.ApplicationClientProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

setDisplayPerUserApps

public void setDisplayPerUserApps(boolean displayPerUserApps)