org.apache.hadoop.yarn.server.resourcemanager

Class RMAppManager

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.RMAppManager

All Implemented Interfaces:

org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>, Recoverable

public class RMAppManager
extends Object
implements org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>, Recoverable

This class manages the list of applications for the resource manager.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	completedAppsInStateStore

Constructor Summary

Constructors

Constructor and Description
RMAppManager(RMContext context, YarnScheduler scheduler, ApplicationMasterService masterService, org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected void	checkAppNumCompletedLimit()
void	checkAppNumCompletedLimit4Test()
protected void	finishApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
void	finishApplication4Test(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)
protected int	getCompletedAppsListSize()
String	getQueuePath(String queueName)
protected String	getUserNameForPlacement(String user, org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context, PlacementManager placementManager)
void	handle(RMAppManagerEvent event)
void	logApplicationSummary(org.apache.hadoop.yarn.api.records.ApplicationId appId)
void	moveApplicationAcrossQueue(org.apache.hadoop.yarn.api.records.ApplicationId applicationId, String targetQueue) moveToQueue will invoke scheduler api to perform move queue operation.
void	recover(RMStateStore.RMState state)
protected void	recoverApplication(ApplicationStateData appState, RMStateStore.RMState rmState)
void	setFederationStateStoreService(FederationStateStoreService stateStoreService)
protected void	submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, long submitTime, String user) Deprecated.
protected void	submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext, long submitTime, org.apache.hadoop.security.UserGroupInformation userUgi)
void	updateApplicationPriority(org.apache.hadoop.security.UserGroupInformation callerUGI, org.apache.hadoop.yarn.api.records.ApplicationId applicationId, org.apache.hadoop.yarn.api.records.Priority newAppPriority) updateApplicationPriority will invoke scheduler api to update the new priority to RM and StateStore.
Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,String>	updateApplicationTimeout(RMApp app, Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,String> newTimeoutInISO8601Format)
protected void	writeAuditLog(org.apache.hadoop.yarn.api.records.ApplicationId appId)

Methods inherited from class java.lang.Object

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

Field Detail

completedAppsInStateStore

protected int completedAppsInStateStore

Constructor Detail

RMAppManager

public RMAppManager(RMContext context,
                    YarnScheduler scheduler,
                    ApplicationMasterService masterService,
                    org.apache.hadoop.yarn.server.security.ApplicationACLsManager applicationACLsManager,
                    org.apache.hadoop.conf.Configuration conf)

Method Detail

logApplicationSummary

@VisibleForTesting
public void logApplicationSummary(org.apache.hadoop.yarn.api.records.ApplicationId appId)

getCompletedAppsListSize

protected int getCompletedAppsListSize()

finishApplication

protected void finishApplication(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)

writeAuditLog

protected void writeAuditLog(org.apache.hadoop.yarn.api.records.ApplicationId appId)

checkAppNumCompletedLimit

protected void checkAppNumCompletedLimit()

submitApplication

@VisibleForTesting
 @Deprecated
protected void submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
                                                                 long submitTime,
                                                                 String user)
                                                          throws org.apache.hadoop.yarn.exceptions.YarnException

Deprecated.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

submitApplication

@VisibleForTesting
protected void submitApplication(org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext submissionContext,
                                                    long submitTime,
                                                    org.apache.hadoop.security.UserGroupInformation userUgi)
                                             throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

recoverApplication

protected void recoverApplication(ApplicationStateData appState,
                                  RMStateStore.RMState rmState)
                           throws Exception

Throws:

Exception

getQueuePath

public String getQueuePath(String queueName)

recover

public void recover(RMStateStore.RMState state)
             throws Exception

Specified by:

recover in interface Recoverable

Throws:

Exception

handle

public void handle(RMAppManagerEvent event)

Specified by:

handle in interface org.apache.hadoop.yarn.event.EventHandler<RMAppManagerEvent>

updateApplicationTimeout

public Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,String> updateApplicationTimeout(RMApp app,
                                                                                                      Map<org.apache.hadoop.yarn.api.records.ApplicationTimeoutType,String> newTimeoutInISO8601Format)
                                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

updateApplicationPriority

public void updateApplicationPriority(org.apache.hadoop.security.UserGroupInformation callerUGI,
                                      org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
                                      org.apache.hadoop.yarn.api.records.Priority newAppPriority)
                               throws org.apache.hadoop.yarn.exceptions.YarnException

updateApplicationPriority will invoke scheduler api to update the new priority to RM and StateStore.

Parameters:

callerUGI - user

applicationId - Application Id

newAppPriority - proposed new application priority

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - Handle exceptions

moveApplicationAcrossQueue

public void moveApplicationAcrossQueue(org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
                                       String targetQueue)
                                throws org.apache.hadoop.yarn.exceptions.YarnException

moveToQueue will invoke scheduler api to perform move queue operation.

Parameters:

applicationId - Application Id.

targetQueue - Target queue to which this app has to be moved.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - Handle exceptions.

getUserNameForPlacement

@VisibleForTesting
protected String getUserNameForPlacement(String user,
                                                            org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext context,
                                                            PlacementManager placementManager)
                                                     throws org.apache.hadoop.yarn.exceptions.YarnException

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

setFederationStateStoreService

@VisibleForTesting
public void setFederationStateStoreService(FederationStateStoreService stateStoreService)

checkAppNumCompletedLimit4Test

@VisibleForTesting
public void checkAppNumCompletedLimit4Test()

finishApplication4Test

@VisibleForTesting
public void finishApplication4Test(org.apache.hadoop.yarn.api.records.ApplicationId applicationId)