Uses of Class
org.apache.hadoop.yarn.exceptions.YarnException
Packages that use YarnException
Package
Description
The Dynamometer tool is used to stress test the HDFS NameNode by setting
up a realistic environment consistent of fake DataNodes and a real NameNode
with a real FS namesystem and near-real user workload (RPCs).
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Package org.apache.hadoop.yarn.service.client contains classes
for YARN Services Client API.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of YarnException in org.apache.hadoop.tools.dynamometer
Methods in org.apache.hadoop.tools.dynamometer that throw YarnException -
Uses of YarnException in org.apache.hadoop.yarn.api
Methods in org.apache.hadoop.yarn.api that throw YarnExceptionModifier and TypeMethodDescriptionApplicationMasterProtocol.allocate(AllocateRequest request) The main interface between anApplicationMasterand theResourceManager.ContainerManagementProtocol.commitLastReInitialization(ContainerId containerId) Commit the Last ReInitialization if possible.ApplicationClientProtocol.deleteReservation(ReservationDeleteRequest request) The interface used by clients to remove an existing Reservation.ApplicationClientProtocol.failApplicationAttempt(FailApplicationAttemptRequest request) The interface used by clients to request theResourceManagerto fail an application attempt.ApplicationMasterProtocol.finishApplicationMaster(FinishApplicationMasterRequest request) The interface used by anApplicationMasterto notify theResourceManagerabout its completion (success or failed).ApplicationClientProtocol.forceKillApplication(KillApplicationRequest request) The interface used by clients to request theResourceManagerto abort submitted application.ApplicationClientProtocol.getAttributesToNodes(GetAttributesToNodesRequest request) The interface used by client to get attributes to nodes mappings available in ResourceManager.ApplicationClientProtocol.getClusterMetrics(GetClusterMetricsRequest request) The interface used by clients to get metrics about the cluster from theResourceManager.ApplicationClientProtocol.getClusterNodeAttributes(GetClusterNodeAttributesRequest request) The interface used by client to get node attributes available in ResourceManager.ApplicationClientProtocol.getClusterNodeLabels(GetClusterNodeLabelsRequest request) The interface used by client to get node labels in the clusterApplicationClientProtocol.getClusterNodes(GetClusterNodesRequest request) The interface used by clients to get a report of all nodes in the cluster from theResourceManager.ContainerManagementProtocol.getContainerStatuses(GetContainerStatusesRequest request) The API used by theApplicationMasterto request for current statuses ofContainers from theNodeManager.org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesResponseApplicationClientProtocol.getLabelsToNodes(org.apache.hadoop.yarn.api.protocolrecords.GetLabelsToNodesRequest request) The interface used by client to get labels to nodes mappings in existing cluster.ContainerManagementProtocol.getLocalizationStatuses(GetLocalizationStatusesRequest request) API to request for the localization statuses of requested containers from the Node Manager.ApplicationClientProtocol.getNewApplication(GetNewApplicationRequest request) The interface used by clients to obtain a newApplicationIdfor submitting new applications.ApplicationClientProtocol.getNewReservation(GetNewReservationRequest request) The interface used by clients to obtain a newReservationIdfor submitting new reservations.ApplicationClientProtocol.getNodesToAttributes(GetNodesToAttributesRequest request) The interface used by client to get node to attributes mappings.org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsResponseApplicationClientProtocol.getNodeToLabels(org.apache.hadoop.yarn.api.protocolrecords.GetNodesToLabelsRequest request) The interface used by client to get node to labels mappings in existing cluster.ApplicationClientProtocol.getQueueInfo(GetQueueInfoRequest request) The interface used by clients to get information about queues from theResourceManager.ApplicationClientProtocol.getQueueUserAcls(GetQueueUserAclsInfoRequest request) The interface used by clients to get information about queue acls for current user from theResourceManager.ApplicationClientProtocol.getResourceProfile(GetResourceProfileRequest request) The interface to get the details for a specific resource profile.ApplicationClientProtocol.getResourceProfiles(GetAllResourceProfilesRequest request) The interface used by clients to get all the resource profiles that are available on the ResourceManager.ApplicationClientProtocol.getResourceTypeInfo(GetAllResourceTypeInfoRequest request) The interface to get the details for a specific resource profile.ContainerManagementProtocol.increaseContainersResource(IncreaseContainersResourceRequest request) Deprecated.ApplicationClientProtocol.listReservations(ReservationListRequest request) The interface used by clients to get the list of reservations in a plan.ContainerManagementProtocol.localize(ResourceLocalizationRequest request) Localize resources required by the container.ApplicationClientProtocol.moveApplicationAcrossQueues(MoveApplicationAcrossQueuesRequest request) Move an application to a new queue.ApplicationMasterProtocol.registerApplicationMaster(RegisterApplicationMasterRequest request) The interface used by a newApplicationMasterto register with theResourceManager.ContainerManagementProtocol.reInitializeContainer(ReInitializeContainerRequest request) ReInitialize the Container with a new Launch Context.ClientSCMProtocol.release(ReleaseSharedCacheResourceRequest request) The interface used by clients to release a resource with theSharedCacheManager.This method is called once an application is no longer using a claimed resource in the shared cache.ContainerManagementProtocol.restartContainer(ContainerId containerId) Restart the container.ContainerManagementProtocol.rollbackLastReInitialization(ContainerId containerId) Rollback the Last ReInitialization if possible.ApplicationClientProtocol.signalToContainer(SignalContainerRequest request) The interface used by clients to request theResourceManagerto signal a container.ContainerManagementProtocol.signalToContainer(SignalContainerRequest request) ContainerManagementProtocol.startContainers(StartContainersRequest request) TheApplicationMasterprovides a list ofStartContainerRequests to aNodeManagerto startContainers allocated to it using this interface.ContainerManagementProtocol.stopContainers(StopContainersRequest request) TheApplicationMasterrequests aNodeManagerto stop a list ofContainers allocated to it using this interface.ApplicationClientProtocol.submitApplication(SubmitApplicationRequest request) The interface used by clients to submit a new application to theResourceManager.ApplicationClientProtocol.submitReservation(ReservationSubmissionRequest request) The interface used by clients to submit a new reservation to theResourceManager.ApplicationClientProtocol.updateApplicationPriority(UpdateApplicationPriorityRequest request) The interface used by client to set priority of an application.ApplicationClientProtocol.updateApplicationTimeouts(UpdateApplicationTimeoutsRequest request) The interface used by client to set ApplicationTimeouts of an application.ContainerManagementProtocol.updateContainer(ContainerUpdateRequest request) The API used by theApplicationMasterto request for resource update of running containers on theNodeManager.ApplicationClientProtocol.updateReservation(ReservationUpdateRequest request) The interface used by clients to update an existing Reservation.ClientSCMProtocol.use(UseSharedCacheResourceRequest request) The interface used by clients to claim a resource with theSharedCacheManager.The client uses a checksum to identify the resource and anApplicationIdto identify which application will be using the resource. -
Uses of YarnException in org.apache.hadoop.yarn.applications.distributedshell
Methods in org.apache.hadoop.yarn.applications.distributedshell that throw YarnException -
Uses of YarnException in org.apache.hadoop.yarn.client.api
Methods in org.apache.hadoop.yarn.client.api that throw YarnExceptionModifier and TypeMethodDescriptionabstract intAppAdminClient.actionCancelUpgrade(String appName) Cancels the upgrade of the service.abstract intAppAdminClient.actionCleanUp(String appName, String userName) Operation to be performed by the RM after an application has completed.abstract intAppAdminClient.actionDecommissionInstances(String appName, List<String> componentInstances) Decommission component instances of a long running service.abstract intAppAdminClient.actionDestroy(String appName) Remove the specification and all application data for a YARN application.abstract intAppAdminClient.actionFlex(String appName, Map<String, String> componentCounts) Change the number of running containers for a component of a YARN application / long-running service.abstract intAppAdminClient.actionLaunch(String fileName, String appName, Long lifetime, String queue) Launch a new YARN application.abstract intAppAdminClient.actionSave(String fileName, String appName, Long lifetime, String queue) Save the specification for a YARN application / long-running service.abstract intAppAdminClient.actionStart(String appName) Start a YARN application from a previously saved specification.abstract intAppAdminClient.actionStop(String appName) Stop a YARN application (attempt to stop gracefully before killing the application).abstract intAppAdminClient.actionUpgradeComponents(String appName, List<String> components) Upgrade components of a long running service.abstract intAppAdminClient.actionUpgradeExpress(String appName, File fileName) Express upgrade a long running service.abstract intAppAdminClient.actionUpgradeInstances(String appName, List<String> componentInstances) Upgrade component instances of a long running service.abstract AllocateResponseAMRMClient.allocate(float progressIndicator) Request additional containers and receive new container allocations.abstract voidTimelineClient.cancelDelegationToken(Token<TimelineDelegationTokenIdentifier> timelineDT) Cancel a timeline delegation token.abstract voidNMClient.commitLastReInitialization(ContainerId containerId) Commit last reInitialization of the specified container.abstract YarnClientApplicationYarnClient.createApplication()Obtain aYarnClientApplicationfor a new application, which in turn contains theApplicationSubmissionContextandGetNewApplicationResponseobjects.abstract GetNewReservationResponseYarnClient.createReservation()Obtain aGetNewReservationResponsefor a new reservation, which contains theReservationIdobject.abstract ReservationDeleteResponseYarnClient.deleteReservation(ReservationDeleteRequest request) The interface used by clients to remove an existing Reservation.abstract intAppAdminClient.enableFastLaunch(String destinationFolder) Upload AM dependencies to HDFS.abstract voidYarnClient.failApplicationAttempt(ApplicationAttemptId applicationAttemptId) Fail an application attempt identified by given ID.YarnClient.getAllQueues()Get information (QueueInfo) about all queues, recursively if there is a hierarchyabstract Token<AMRMTokenIdentifier>YarnClient.getAMRMToken(ApplicationId appId) Get the AMRM token of the application.abstract ApplicationAttemptReportAHSClient.getApplicationAttemptReport(ApplicationAttemptId applicationAttemptId) Get a report of the given ApplicationAttempt.abstract ApplicationAttemptReportYarnClient.getApplicationAttemptReport(ApplicationAttemptId applicationAttemptId) Get a report of the given ApplicationAttempt.abstract List<ApplicationAttemptReport>AHSClient.getApplicationAttempts(ApplicationId applicationId) Get a report of all (ApplicationAttempts) of Application in the cluster.abstract List<ApplicationAttemptReport>YarnClient.getApplicationAttempts(ApplicationId applicationId) Get a report of all (ApplicationAttempts) of Application in the cluster.abstract ApplicationReportAHSClient.getApplicationReport(ApplicationId appId) Get a report of the given Application.abstract ApplicationReportYarnClient.getApplicationReport(ApplicationId appId) Get a report of the given Application.abstract List<ApplicationReport>AHSClient.getApplications()Get a report (ApplicationReport) of all Applications in the cluster.abstract List<ApplicationReport>YarnClient.getApplications()Get a report (ApplicationReport) of all Applications in the cluster.abstract List<ApplicationReport>YarnClient.getApplications(EnumSet<YarnApplicationState> applicationStates) Get a report (ApplicationReport) of Applications matching the given application states in the cluster.abstract List<ApplicationReport>YarnClient.getApplications(Set<String> applicationTypes) Get a report (ApplicationReport) of Applications matching the given application types in the cluster.abstract List<ApplicationReport>YarnClient.getApplications(Set<String> applicationTypes, EnumSet<YarnApplicationState> applicationStates) Get a report (ApplicationReport) of Applications matching the given application types and application states in the cluster.abstract List<ApplicationReport>YarnClient.getApplications(Set<String> applicationTypes, EnumSet<YarnApplicationState> applicationStates, Set<String> applicationTags) Get a report (ApplicationReport) of Applications matching the given application types, application states and application tags in the cluster.abstract List<ApplicationReport>YarnClient.getApplications(Set<String> queues, Set<String> users, Set<String> applicationTypes, EnumSet<YarnApplicationState> applicationStates) Get a report (ApplicationReport) of Applications matching the given users, queues, application types and application states in the cluster.YarnClient.getApplications(GetApplicationsRequest request) Get a list of ApplicationReports that match the givenGetApplicationsRequest.abstract Map<NodeAttributeKey,List<NodeToAttributeValue>> YarnClient.getAttributesToNodes(Set<NodeAttributeKey> attributes) The interface used by client to get mapping of AttributeKey to associated NodeToAttributeValue list for specified node attributeKeys in the cluster.YarnClient.getChildQueueInfos(String parent) Get information (QueueInfo) about all the immediate children queues of the given queueabstract Set<NodeAttributeInfo>YarnClient.getClusterAttributes()The interface used by client to get node attributes in the cluster.YarnClient.getClusterNodeLabels()The interface used by client to get node labels in the clusterabstract ContainerReportAHSClient.getContainerReport(ContainerId containerId) Get a report of the given Container.abstract ContainerReportYarnClient.getContainerReport(ContainerId containerId) Get a report of the given Container.abstract List<ContainerReport>AHSClient.getContainers(ApplicationAttemptId applicationAttemptId) Get a report of all (Containers) of ApplicationAttempt in the cluster.abstract List<ContainerReport>YarnClient.getContainers(ApplicationAttemptId applicationAttemptId) Get a report of all (Containers) of ApplicationAttempt in the cluster.abstract ContainerStatusNMClient.getContainerStatus(ContainerId containerId, NodeId nodeId) Query the status of a container.abstract Token<TimelineDelegationTokenIdentifier>TimelineClient.getDelegationToken(String renewer) Get a delegation token so as to be able to talk to the timeline server in a secure way.abstract StringAppAdminClient.getInstances(String appName, List<String> components, String version, List<String> containerStates) YarnClient.getLabelsToNodes()The interface used by client to get labels to nodes mapping in existing clusterYarnClient.getLabelsToNodes(Set<String> labels) The interface used by client to get labels to nodes mapping for specified labels in existing clusterNMClient.getLocalizationStatuses(ContainerId containerId, NodeId nodeId) Get the localization statuses of a container.abstract List<NodeReport>YarnClient.getNodeReports(NodeState... states) Get a report of nodes (NodeReport) in the cluster.abstract Map<String,Set<NodeAttribute>> YarnClient.getNodeToAttributes(Set<String> hostNames) The interface used by client to get all node to attribute mapping in existing cluster.YarnClient.getNodeToLabels()The interface used by client to get node to labels mappings in existing clusterabstract List<QueueUserACLInfo>YarnClient.getQueueAclsInfo()Get information about acls for current user on all the existing queues.abstract QueueInfoYarnClient.getQueueInfo(String queueName) Get information (QueueInfo) about a given queue.abstract QueueInfoYarnClient.getQueueInfo(String queueName, String subClusterId) Get information (QueueInfo) about a given queue.abstract ResourceYarnClient.getResourceProfile(String profile) Get the details of a specific resource profile from the RM.YarnClient.getResourceProfiles()Get the resource profiles available in the RM.abstract List<org.apache.hadoop.yarn.api.records.ResourceTypeInfo>YarnClient.getResourceTypeInfo()Get available resource types supported by RM.abstract TokenYarnClient.getRMDelegationToken(Text renewer) Get a delegation token so as to be able to talk to YARN using those tokens.YarnClient.getRootQueueInfos()Get information (QueueInfo) about top level queues.abstract StringAppAdminClient.getStatusString(String appIdOrName) Get detailed app specific status string for a YARN application.abstract YarnClusterMetricsYarnClient.getYarnClusterMetrics()Get metrics (YarnClusterMetrics) about the cluster.abstract voidNMClient.increaseContainerResource(Container container) Deprecated.abstract intAppAdminClient.initiateUpgrade(String appName, String fileName, boolean autoFinalize) Initiate upgrade of a long running service.abstract voidYarnClient.killApplication(ApplicationId applicationId) Kill an application identified by given ID.abstract voidYarnClient.killApplication(ApplicationId applicationId, String diagnostics) Kill an application identified by given ID.abstract ReservationListResponseYarnClient.listReservations(ReservationListRequest request) The interface used by clients to get the list of reservations in a plan.voidNMClient.localize(ContainerId containerId, NodeId nodeId, Map<String, LocalResource> localResources) Localize resources for a container.abstract voidYarnClient.moveApplicationAcrossQueues(ApplicationId appId, String queue) Attempts to move the given application to the given queue.abstract voidTimelineClient.putDomain(ApplicationAttemptId appAttemptId, TimelineDomain domain) Send the information of a domain to the timeline server.abstract voidTimelineClient.putDomain(TimelineDomain domain) Send the information of a domain to the timeline server.abstract TimelinePutResponseTimelineClient.putEntities(ApplicationAttemptId appAttemptId, TimelineEntityGroupId groupId, TimelineEntity... entities) Send the information of a number of conceptual entities to the timeline server.abstract TimelinePutResponseTimelineClient.putEntities(TimelineEntity... entities) Send the information of a number of conceptual entities to the timeline server.abstract RegisterApplicationMasterResponseAMRMClient.registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl) Register the application master.AMRMClient.registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl, Map<Set<String>, PlacementConstraint> placementConstraints) Register the application master.abstract voidNMClient.reInitializeContainer(ContainerId containerId, ContainerLaunchContext containerLaunchContex, boolean autoCommit) Re-Initialize the Container.abstract voidSharedCacheClient.release(ApplicationId applicationId, String resourceKey) The method to release a resource with theSharedCacheManager.This method is called once an application is no longer using a claimed resource in the shared cache.abstract longTimelineClient.renewDelegationToken(Token<TimelineDelegationTokenIdentifier> timelineDT) Renew a timeline delegation token.abstract voidNMClient.restartContainer(ContainerId containerId) Restart the specified container.abstract voidNMClient.rollbackLastReInitialization(ContainerId containerId) Rollback last reInitialization of the specified container.abstract voidYarnClient.signalToContainer(ContainerId containerId, SignalContainerCommand command) Signal a container identified by given ID.abstract Map<String,ByteBuffer> NMClient.startContainer(Container container, ContainerLaunchContext containerLaunchContext) Start an allocated container.abstract voidNMClient.stopContainer(ContainerId containerId, NodeId nodeId) Stop an started container.abstract ApplicationIdYarnClient.submitApplication(ApplicationSubmissionContext appContext) Submit a new application toYARN.It is a blocking call - it will not returnApplicationIduntil the submitted application is submitted successfully and accepted by the ResourceManager.abstract ReservationSubmissionResponseYarnClient.submitReservation(ReservationSubmissionRequest request) The interface used by clients to submit a new reservation to theResourceManager.abstract voidAMRMClient.unregisterApplicationMaster(FinalApplicationStatus appStatus, String appMessage, String appTrackingUrl) Unregister the application master.abstract PriorityYarnClient.updateApplicationPriority(ApplicationId applicationId, Priority priority) The interface used by client to set priority of an applicationYarnClient.updateApplicationTimeouts(UpdateApplicationTimeoutsRequest request) abstract voidNMClient.updateContainerResource(Container container) Update the resources of a container.abstract ReservationUpdateResponseYarnClient.updateReservation(ReservationUpdateRequest request) The interface used by clients to update an existing Reservation.abstract URLSharedCacheClient.use(ApplicationId applicationId, String resourceKey) The method to claim a resource with theSharedCacheManager.The client uses a checksum to identify the resource and anApplicationIdto identify which application will be using the resource. -
Uses of YarnException in org.apache.hadoop.yarn.client.api.async
Methods in org.apache.hadoop.yarn.client.api.async that throw YarnExceptionModifier and TypeMethodDescriptionabstract RegisterApplicationMasterResponseAMRMClientAsync.registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl) Registers this application master with the resource manager.AMRMClientAsync.registerApplicationMaster(String appHostName, int appHostPort, String appTrackingUrl, Map<Set<String>, PlacementConstraint> placementConstraints) Register the application master.voidAMRMClientAsync.registerTimelineV2Client(org.apache.hadoop.yarn.client.api.TimelineV2Client timelineClient) Register TimelineClient to AMRMClient.abstract voidAMRMClientAsync.unregisterApplicationMaster(FinalApplicationStatus appStatus, String appMessage, String appTrackingUrl) Unregister the application master. -
Uses of YarnException in org.apache.hadoop.yarn.client.cli
Methods in org.apache.hadoop.yarn.client.cli that throw YarnException -
Uses of YarnException in org.apache.hadoop.yarn.exceptions
Subclasses of YarnException in org.apache.hadoop.yarn.exceptionsModifier and TypeClassDescriptionclassThis exception is thrown on(GetApplicationAttemptReportRequest)API when the Application Attempt doesn't exist in Application History Server orApplicationMasterProtocol.allocate(AllocateRequest)if application doesn't exist in RM.classException to be thrown when Client submit an application without providingApplicationIdinApplicationSubmissionContext.classThis exception is thrown on(GetApplicationReportRequest)API when the Application doesn't exist in RM and AHSclassThis exception is thrown on unrecoverable configuration errors.classThis exception is thrown on(GetContainerReportRequest)API when the container doesn't exist in AHSclassThis exception is thrown when a feature is being used which is not enabled yet. -
Uses of YarnException in org.apache.hadoop.yarn.service.client
Methods in org.apache.hadoop.yarn.service.client that throw YarnExceptionModifier and TypeMethodDescriptionintServiceClient.actionBuild(Service service) intServiceClient.actionCancelUpgrade(String appName) intServiceClient.actionCleanUp(String appName, String userName) ServiceClient.actionCreate(Service service) intServiceClient.actionDecommissionInstances(String appName, List<String> componentInstances) intServiceClient.actionDestroy(String serviceName) intServiceClient.actionFlex(String serviceName, Map<String, String> componentCountStrings) intServiceClient.actionLaunch(String fileName, String serviceName, Long lifetime, String queue) intServiceClient.actionSave(String fileName, String serviceName, Long lifetime, String queue) intServiceClient.actionStart(String serviceName) ServiceClient.actionStartAndGetId(String serviceName) intServiceClient.actionStop(String serviceName) intServiceClient.actionStop(String serviceName, boolean waitForAppStopped) intServiceClient.actionUpgrade(Service service, List<Container> compInstances) intServiceClient.actionUpgradeComponents(String appName, List<String> components) intServiceClient.actionUpgradeExpress(String appName, File path) intServiceClient.actionUpgradeExpress(Service service) intServiceClient.actionUpgradeInstances(String appName, List<String> componentInstances) protected PathServiceClient.addJarResource(String serviceName, Map<String, LocalResource> localResources) protected org.apache.hadoop.yarn.service.ClientAMProtocolServiceClient.createAMProxy(String serviceName, ApplicationReport appReport) intServiceClient.enableFastLaunch(String destinationFolder) ServiceClient.flexByRestService(String serviceName, Map<String, Long> componentCounts) ServiceClient.getContainers(String appName, List<String> components, String version, List<ContainerState> containerStates) ServiceClient.getInstances(String appName, List<String> components, String version, List<String> containerStates) ServiceClient.getStatusString(String appIdOrName) intServiceClient.initiateUpgrade(String appName, String fileName, boolean autoFinalize) intServiceClient.initiateUpgrade(Service service) ServiceClient.loadAppJsonFromLocalFS(String fileName, String serviceName, Long lifetime, String queue) ServiceClient.updateLifetime(String serviceName, long lifetime) -
Uses of YarnException in org.apache.hadoop.yarn.util
Methods in org.apache.hadoop.yarn.util that throw YarnExceptionModifier and TypeMethodDescriptionvoidResourceCalculatorProcessTree.initialize()Initialize the object.