Uses of Class
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.ResourceHandlerException
Packages that use ResourceHandlerException
Package
Description
Package org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.
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.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionAbstractCGroupsCpuResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration conf) AbstractCGroupsMemoryResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration conf) CGroupsBlkioResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) CGroupsMemoryResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration conf) NetworkPacketTaggingHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrapping network-tagging-handler - mounts net_cls controller.ResourceHandler.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrap resource susbsystem.ResourceHandlerChain.bootstrap(org.apache.hadoop.conf.Configuration configuration) TrafficControlBandwidthHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) Bootstrapping 'outbound-bandwidth' resource handler - mounts net_cls controller and bootstraps a traffic control bandwidth shaping hierarchyprotected abstract booleanAbstractCGroupsCpuResourceHandler.cpuLimitExists(String path) booleanCGroupsCpuResourceHandlerImpl.cpuLimitExists(String cgroupPath) booleanCGroupsV2CpuResourceHandlerImpl.cpuLimitExists(String cgroupPath) AbstractCGroupsHandler.createCGroup(CGroupsHandler.CGroupController controller, String cGroupId) CGroupsHandler.createCGroup(CGroupsHandler.CGroupController controller, String cGroupId) Creates a cgroup for a given controller.voidAbstractCGroupsHandler.deleteCGroup(CGroupsHandler.CGroupController controller, String cGroupId) voidCGroupsHandler.deleteCGroup(CGroupsHandler.CGroupController controller, String cGroupId) Deletes the specified cgroup.booleanCGroupsMountConfig.ensureMountPathIsDefined()TrafficControlBandwidthHandlerImpl.getBytesSentPerContainer()Returns total bytes sent per container to be used for metrics tracking purposes.AbstractCGroupsHandler.getCGroupParam(CGroupsHandler.CGroupController controller, String cGroupId, String param) CGroupsHandler.getCGroupParam(CGroupsHandler.CGroupController controller, String cGroupId, String param) reads a cgroup parameter value, given a controller, cgroup id, parameter.static ResourceHandlerChainResourceHandlerModule.getConfiguredResourceHandlerChain(org.apache.hadoop.conf.Configuration conf, Context nmContext) static ResourceHandlerResourceHandlerModule.getNetworkTaggingHandler(org.apache.hadoop.conf.Configuration conf) protected voidAbstractCGroupsHandler.init()static DiskResourceHandlerResourceHandlerModule.initDiskResourceHandler(org.apache.hadoop.conf.Configuration conf) voidAbstractCGroupsHandler.initializeCGroupController(CGroupsHandler.CGroupController controller) Mount cgroup or use existing mount point based on configuration.voidCGroupsHandler.initializeCGroupController(CGroupsHandler.CGroupController controller) Mounts or initializes a cgroup controller.static MemoryResourceHandlerResourceHandlerModule.initMemoryResourceHandler(org.apache.hadoop.conf.Configuration conf) static ResourceHandlerResourceHandlerModule.initNetworkResourceHandler(org.apache.hadoop.conf.Configuration conf) ResourceHandlerModule.initOutboundBandwidthResourceHandler(org.apache.hadoop.conf.Configuration conf) protected abstract voidAbstractCGroupsHandler.mountCGroupController(CGroupsHandler.CGroupController controller) AbstractCGroupsCpuResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) AbstractCGroupsMemoryResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) CGroupsBlkioResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) NetworkPacketTaggingHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Cleanup operation once container is completed - deletes cgroup.ResourceHandler.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Perform any tasks necessary after container completion.ResourceHandlerChain.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) TrafficControlBandwidthHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) Cleanup operations once container is completed - deletes cgroup and removes traffic shaping rule(s).Pre-start hook for network-tagging-handler.Prepare a resource environment for container launchPre-start hook for 'outbound-bandwidth' resource.AbstractCGroupsCpuResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) AbstractCGroupsMemoryResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) CGroupsBlkioResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) NetworkPacketTaggingHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Reacquires state for a container - reads the classid from the cgroup being used for the container being reacquired.ResourceHandler.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Require state for container that was already launchedResourceHandlerChain.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) TrafficControlBandwidthHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) Reacquires state for a container - reads the classid from the cgroup being used for the container being reacquiredAbstractCGroupsCpuResourceHandler.teardown()AbstractCGroupsMemoryResourceHandler.teardown()CGroupsBlkioResourceHandlerImpl.teardown()NetworkPacketTaggingHandlerImpl.teardown()ResourceHandler.teardown()Teardown environment for resource subsystem if requested.ResourceHandlerChain.teardown()TrafficControlBandwidthHandlerImpl.teardown()protected abstract voidAbstractCGroupsCpuResourceHandler.updateCgroupCpuWeight(String cgroupId, int weight) protected voidCGroupsCpuResourceHandlerImpl.updateCgroupCpuWeight(String cgroupId, int weight) protected voidCGroupsV2CpuResourceHandlerImpl.updateCgroupCpuWeight(String cgroupId, int weight) protected abstract voidAbstractCGroupsCpuResourceHandler.updateCgroupMaxCpuLimit(String cgroupId, String quota, String period) protected voidCGroupsCpuResourceHandlerImpl.updateCgroupMaxCpuLimit(String cgroupId, String quota, String period) protected voidCGroupsV2CpuResourceHandlerImpl.updateCgroupMaxCpuLimit(String cgroupId, String max, String period) voidAbstractCGroupsHandler.updateCGroupParam(CGroupsHandler.CGroupController controller, String cGroupId, String param, String value) voidCGroupsHandler.updateCGroupParam(CGroupsHandler.CGroupController controller, String cGroupId, String param, String value) updates a cgroup parameter, given a controller, cgroup id, parameter name.AbstractCGroupsCpuResourceHandler.updateContainer(Container container) AbstractCGroupsMemoryResourceHandler.updateContainer(Container container) CGroupsBlkioResourceHandlerImpl.updateContainer(Container container) NetworkPacketTaggingHandlerImpl.updateContainer(Container container) ResourceHandler.updateContainer(Container container) Update state for container that was already launchedResourceHandlerChain.updateContainer(Container container) TrafficControlBandwidthHandlerImpl.updateContainer(Container container) protected abstract voidAbstractCGroupsHandler.updateEnabledControllersInHierarchy(File yarnHierarchy, CGroupsHandler.CGroupController controller) protected abstract voidAbstractCGroupsMemoryResourceHandler.updateGuaranteedMemoryLimits(String cgroupId, long containerSoftLimit) protected voidCGroupsMemoryResourceHandlerImpl.updateGuaranteedMemoryLimits(String cgroupId, long containerSoftLimit) protected voidCGroupsV2MemoryResourceHandlerImpl.updateGuaranteedMemoryLimits(String cgroupId, long containerSoftLimit) protected abstract voidAbstractCGroupsMemoryResourceHandler.updateMemoryHardLimit(String cgroupId, long containerHardLimit) protected voidCGroupsMemoryResourceHandlerImpl.updateMemoryHardLimit(String cgroupId, long containerHardLimit) protected voidCGroupsV2MemoryResourceHandlerImpl.updateMemoryHardLimit(String cgroupId, long containerHardLimit) protected abstract voidAbstractCGroupsMemoryResourceHandler.updateOpportunisticMemoryLimits(String cgroupId) protected voidCGroupsMemoryResourceHandlerImpl.updateOpportunisticMemoryLimits(String cgroupId) protected voidCGroupsV2MemoryResourceHandlerImpl.updateOpportunisticMemoryLimits(String cgroupId) -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.fpga
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.fpga that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionFpgaResourceAllocator.assignFpga(String type, long count, Container container, String ipidHash) AssignFpgaResourceAllocator.FpgaAllocationwith preferred IPID, if no, with random FPGAsFpgaResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) FpgaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) FpgaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) voidFpgaResourceAllocator.recoverAssignedFpgas(org.apache.hadoop.yarn.api.records.ContainerId containerId) FpgaResourceHandlerImpl.teardown()FpgaResourceHandlerImpl.updateContainer(Container container) -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionorg.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu.GpuResourceAllocator.GpuAllocationGpuResourceAllocator.assignGpus(Container container) Assign GPU to the specified container.GpuResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) GpuResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) GpuResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) voidGpuResourceAllocator.recoverAssignedGpus(org.apache.hadoop.yarn.api.records.ContainerId containerId) GpuResourceHandlerImpl.teardown()GpuResourceHandlerImpl.updateContainer(Container container) -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.numa
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.numa that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionNumaResourceAllocator.allocateNumaNodes(Container container) Allocates the available NUMA nodes for the requested containerId with resource in a round robin fashion.NumaResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) NumaResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) NumaResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) voidNumaResourceAllocator.releaseNumaResource(org.apache.hadoop.yarn.api.records.ContainerId containerId) Release assigned NUMA resources for the container.NumaResourceHandlerImpl.teardown()NumaResourceHandlerImpl.updateContainer(Container container) -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec
Constructors in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec that throw ResourceHandlerException -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionorg.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.deviceframework.DeviceMappingManager.DeviceAllocationDeviceMappingManager.assignDevices(String resourceName, Container container) DeviceResourceHandlerImpl.bootstrap(org.apache.hadoop.conf.Configuration configuration) DeviceResourceHandlerImpl.postComplete(org.apache.hadoop.yarn.api.records.ContainerId containerId) DeviceResourceHandlerImpl.reacquireContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId) voidDeviceMappingManager.recoverAssignedDevices(String resourceName, org.apache.hadoop.yarn.api.records.ContainerId containerId) DeviceResourceHandlerImpl.teardown()DeviceResourceHandlerImpl.updateContainer(Container container) -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga that throw ResourceHandlerExceptionModifier and TypeMethodDescriptionFpgaDiscoverer.discover()Get available devices minor numbers from toolchain or static configuration. -
Uses of ResourceHandlerException in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga.discovery
Methods in org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga.discovery that throw ResourceHandlerException