Package org.apache.hadoop.yarn.server.resourcemanager

Class AdminService

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.server.resourcemanager.AdminService

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.ha.HAServiceProtocol, org.apache.hadoop.service.Service, org.apache.hadoop.tools.GetUserMappingsProtocol, org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

public class AdminService
extends org.apache.hadoop.service.CompositeService
implements org.apache.hadoop.ha.HAServiceProtocol, org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hadoop.ha.HAServiceProtocol

org.apache.hadoop.ha.HAServiceProtocol.HAServiceState, org.apache.hadoop.ha.HAServiceProtocol.RequestSource, org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo

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

org.apache.hadoop.service.Service.STATE

Field Summary

Fields inherited from class org.apache.hadoop.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Fields inherited from interface org.apache.hadoop.tools.GetUserMappingsProtocol

versionID

Fields inherited from interface org.apache.hadoop.ha.HAServiceProtocol

versionID

Constructor Summary

Constructors

Constructor	Description
AdminService(ResourceManager rm)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse	addToClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesResponse	batchSaveFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesRequest request)	In YARN-Federation mode, this method provides a way to save queue policies in batches.
org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesResponse	checkForDecommissioningNodes(org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesRequest checkForDecommissioningNodesRequest)
org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationResponse	deleteFederationApplication(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesResponse	deleteFederationPoliciesByQueues(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterResponse	deregisterSubCluster(org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterRequest request)	In YARN Federation mode, We allow users to mark subClusters With no heartbeat for a long time as SC_LOST state.
org.apache.hadoop.security.authorize.AccessControlList	getAccessControlList()
org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersResponse	getFederationSubClusters(org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersRequest request)
String[]	getGroupsForUser(String user)
org.apache.hadoop.ipc.RPC.Server	getServer()
org.apache.hadoop.ha.HAServiceStatus	getServiceStatus()	Return the HA status of this RM.
org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesResponse	listFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesRequest request)
protected org.apache.hadoop.conf.Configuration	loadNewConfiguration()
org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingResponse	mapAttributesToNodes(org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingRequest request)
void	monitorHealth()
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse	refreshAdminAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityResponse	refreshClusterMaxPriority(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResponse	refreshNodes(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesResponse	refreshNodesResources(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesRequest request)
void	refreshQueues()
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse	refreshQueues(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsResponse	refreshServiceAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse	refreshSuperUserGroupsConfiguration(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse	refreshUserToGroupsMappings(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsResponse	removeFromClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeResponse	replaceLabelsOnNode(org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeRequest request)
org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyResponse	saveFederationQueuePolicy(org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyRequest request)	In YARN-Federation mode, We will be storing the Policy information for Queues.
void	serviceInit(org.apache.hadoop.conf.Configuration conf)
protected void	serviceStart()
protected void	serviceStop()
protected void	startServer()
protected void	stopServer()
void	transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
void	transitionToObserver(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
void	transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse	updateNodeResource(org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest request)

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

addIfService, addService, getServices, removeService

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

Constructor Details

AdminService

public AdminService(ResourceManager rm)

Method Details

serviceInit

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

Overrides:

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

Throws:

Exception

serviceStart

protected void serviceStart()
                     throws Exception

Overrides:

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

Throws:

Exception

serviceStop

protected void serviceStop()
                    throws Exception

Overrides:

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

Throws:

Exception

startServer

protected void startServer()
                    throws Exception

Throws:

Exception

stopServer

protected void stopServer()
                   throws Exception

Throws:

Exception

monitorHealth

public void monitorHealth()
                   throws IOException

Specified by:

monitorHealth in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

IOException

transitionToActive

public void transitionToActive(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
                        throws IOException

Specified by:

transitionToActive in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

IOException

transitionToStandby

public void transitionToStandby(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
                         throws IOException

Specified by:

transitionToStandby in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

IOException

transitionToObserver

public void transitionToObserver(org.apache.hadoop.ha.HAServiceProtocol.StateChangeRequestInfo reqInfo)
                          throws IOException

Specified by:

transitionToObserver in interface org.apache.hadoop.ha.HAServiceProtocol

Throws:

IOException

getServiceStatus

public org.apache.hadoop.ha.HAServiceStatus getServiceStatus()
                                                      throws IOException

Return the HA status of this RM. This includes the current state and whether the RM is ready to become active.

Specified by:

getServiceStatus in interface org.apache.hadoop.ha.HAServiceProtocol

Returns:

HAServiceStatus of the current RM

Throws:

IOException - if the caller does not have permissions

refreshQueues

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesResponse refreshQueues(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshQueuesRequest request)
                                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
org.apache.hadoop.ipc.StandbyException

Specified by:

refreshQueues in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

org.apache.hadoop.ipc.StandbyException

loadNewConfiguration

protected org.apache.hadoop.conf.Configuration loadNewConfiguration()
                                                             throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

refreshQueues

@Private
public void refreshQueues()
                   throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

refreshNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResponse refreshNodes(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesRequest request)
                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException,
org.apache.hadoop.ipc.StandbyException

Specified by:

refreshNodes in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

org.apache.hadoop.ipc.StandbyException

refreshSuperUserGroupsConfiguration

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse refreshSuperUserGroupsConfiguration(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest request)
                                                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

refreshSuperUserGroupsConfiguration in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshUserToGroupsMappings

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshUserToGroupsMappingsRequest request)
                                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

refreshUserToGroupsMappings in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshAdminAcls

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsResponse refreshAdminAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshAdminAclsRequest request)
                                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

refreshAdminAcls in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshServiceAcls

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsResponse refreshServiceAcls(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshServiceAclsRequest request)
                                                                                                throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

refreshServiceAcls in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getGroupsForUser

public String[] getGroupsForUser(String user)
                          throws IOException

Specified by:

getGroupsForUser in interface org.apache.hadoop.tools.GetUserMappingsProtocol

Throws:

IOException

updateNodeResource

public org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceResponse updateNodeResource(org.apache.hadoop.yarn.server.api.protocolrecords.UpdateNodeResourceRequest request)
                                                                                                throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

updateNodeResource in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

refreshNodesResources

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesResponse refreshNodesResources(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshNodesResourcesRequest request)
                                                                                                      throws org.apache.hadoop.yarn.exceptions.YarnException,
org.apache.hadoop.ipc.StandbyException

Specified by:

refreshNodesResources in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

org.apache.hadoop.ipc.StandbyException

getAccessControlList

@VisibleForTesting
public org.apache.hadoop.security.authorize.AccessControlList getAccessControlList()

getServer

@VisibleForTesting
public org.apache.hadoop.ipc.RPC.Server getServer()

addToClusterNodeLabels

public org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsResponse addToClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.AddToClusterNodeLabelsRequest request)
                                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

addToClusterNodeLabels in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

removeFromClusterNodeLabels

public org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsResponse removeFromClusterNodeLabels(org.apache.hadoop.yarn.server.api.protocolrecords.RemoveFromClusterNodeLabelsRequest request)
                                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

removeFromClusterNodeLabels in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

replaceLabelsOnNode

public org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeResponse replaceLabelsOnNode(org.apache.hadoop.yarn.server.api.protocolrecords.ReplaceLabelsOnNodeRequest request)
                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

replaceLabelsOnNode in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

checkForDecommissioningNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesResponse checkForDecommissioningNodes(org.apache.hadoop.yarn.server.api.protocolrecords.CheckForDecommissioningNodesRequest checkForDecommissioningNodesRequest)
                                                                                                                    throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

checkForDecommissioningNodes in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

refreshClusterMaxPriority

public org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityResponse refreshClusterMaxPriority(org.apache.hadoop.yarn.server.api.protocolrecords.RefreshClusterMaxPriorityRequest request)
                                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

refreshClusterMaxPriority in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

mapAttributesToNodes

public org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingResponse mapAttributesToNodes(org.apache.hadoop.yarn.server.api.protocolrecords.NodesToAttributesMappingRequest request)
                                                                                                        throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

mapAttributesToNodes in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deregisterSubCluster

public org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterResponse deregisterSubCluster(org.apache.hadoop.yarn.server.api.protocolrecords.DeregisterSubClusterRequest request)
                                                                                                    throws org.apache.hadoop.yarn.exceptions.YarnException

In YARN Federation mode, We allow users to mark subClusters With no heartbeat for a long time as SC_LOST state. RM does not support deregisterSubCluster, deregisterSubCluster is supported by Router. If we include a specific subClusterId in the request, check for the specified subCluster. If subClusterId is empty, all subClusters are checked.

Specified by:

deregisterSubCluster in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Parameters:

request - deregisterSubCluster request. The request contains the id of to deregister sub-cluster.

Returns:

Response from deregisterSubCluster.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - exceptions from yarn servers.

saveFederationQueuePolicy

public org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyResponse saveFederationQueuePolicy(org.apache.hadoop.yarn.server.api.protocolrecords.SaveFederationQueuePolicyRequest request)
                                                                                                              throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

In YARN-Federation mode, We will be storing the Policy information for Queues. RM does not support saveFederationQueuePolicy, saveFederationQueuePolicy is supported by Router.

Specified by:

saveFederationQueuePolicy in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Parameters:

request - saveFederationQueuePolicy Request

Returns:

Response from saveFederationQueuePolicy.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - exceptions from yarn servers.

IOException - if an IO error occurred.

batchSaveFederationQueuePolicies

public org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesResponse batchSaveFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.BatchSaveFederationQueuePoliciesRequest request)
                                                                                                                            throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

In YARN-Federation mode, this method provides a way to save queue policies in batches. RM does not support batchSaveFederationQueuePolicies, batchSaveFederationQueuePolicies is supported by Router.

Specified by:

batchSaveFederationQueuePolicies in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Parameters:

request - BatchSaveFederationQueuePolicies Request

Returns:

Response from batchSaveFederationQueuePolicies.

Throws:

org.apache.hadoop.yarn.exceptions.YarnException - exceptions from yarn servers.

IOException - if an IO error occurred.

listFederationQueuePolicies

public org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesResponse listFederationQueuePolicies(org.apache.hadoop.yarn.server.api.protocolrecords.QueryFederationQueuePoliciesRequest request)
                                                                                                                   throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

listFederationQueuePolicies in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteFederationApplication

public org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationResponse deleteFederationApplication(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationApplicationRequest request)
                                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

deleteFederationApplication in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

getFederationSubClusters

public org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersResponse getFederationSubClusters(org.apache.hadoop.yarn.server.api.protocolrecords.GetSubClustersRequest request)
                                                                                                  throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getFederationSubClusters in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

deleteFederationPoliciesByQueues

public org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesResponse deleteFederationPoliciesByQueues(org.apache.hadoop.yarn.server.api.protocolrecords.DeleteFederationQueuePoliciesRequest request)
                                                                                                                         throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

deleteFederationPoliciesByQueues in interface org.apache.hadoop.yarn.server.api.ResourceManagerAdministrationProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException