Uses of Class
org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptions.PlanningException
Packages that use PlanningException
Package
Description
-
Uses of PlanningException in org.apache.hadoop.yarn.server.resourcemanager.reservation
Methods in org.apache.hadoop.yarn.server.resourcemanager.reservation that throw PlanningExceptionModifier and TypeMethodDescriptionbooleanInMemoryPlan.addReservation(ReservationAllocation reservation, boolean isRecovering) booleanPlanEdit.addReservation(ReservationAllocation reservation, boolean isRecovering) Add a newReservationAllocationto the plan.voidPlanEdit.archiveCompletedReservations(long tick) Method invoked to garbage collect old reservations.CapacityOverTimePolicy.availableResources(RLESparseResourceAllocation available, Plan plan, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId, long start, long end) NoOverCommitPolicy.availableResources(RLESparseResourceAllocation available, Plan plan, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId, long start, long end) SharingPolicy.availableResources(RLESparseResourceAllocation available, Plan plan, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId, long start, long end) This method provide a (partial) instantaneous validation by applying business rules (such as max number of parallel containers allowed for a user).booleanPlanEdit.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationID) Delete an existingReservationAllocationfrom the plan identified uniquely by itsReservationId.InMemoryPlan.getAvailableResourceOverTime(String user, org.apache.hadoop.yarn.api.records.ReservationId oldId, long start, long end, long period) InMemoryPlan.getCumulativeLoadOverTime(long start, long end) static RLESparseResourceAllocationRLESparseResourceAllocation.merge(org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc, org.apache.hadoop.yarn.api.records.Resource clusterResource, RLESparseResourceAllocation a, RLESparseResourceAllocation b, RLESparseResourceAllocation.RLEOperator operator, long start, long end) Merges the range start to end of twoRLESparseResourceAllocationusing a givenRLEOperator.booleanInMemoryPlan.updateReservation(ReservationAllocation reservation) booleanPlanEdit.updateReservation(ReservationAllocation reservation) Updates an existingReservationAllocationin the plan.voidCapacityOverTimePolicy.validate(Plan plan, ReservationAllocation reservation) The validation algorithm walks over the RLE encoded allocation and checks that for all transition points (when the start or end of the checking window encounters a value in the RLE).voidNoOverCommitPolicy.validate(Plan plan, ReservationAllocation reservation) voidSharingPolicy.validate(Plan plan, ReservationAllocation newAllocation) This method runs the policy validation logic, and return true/false on whether theReservationAllocationis acceptable according to this sharing policy. -
Uses of PlanningException in org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptions
Subclasses of PlanningException in org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptionsModifier and TypeClassDescriptionclassThis exception is thrown if the request made is not syntactically valid.classThis exception is thrown if the user quota is exceed while accepting or updating a reservation.classThis exception indicate that the reservation that has been attempted, would exceed the physical resources available in thePlanat the moment. -
Uses of PlanningException in org.apache.hadoop.yarn.server.resourcemanager.reservation.planning
Methods in org.apache.hadoop.yarn.server.resourcemanager.reservation.planning that throw PlanningExceptionModifier and TypeMethodDescriptionprotected booleanPlanningAlgorithm.allocateUser(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract, ReservationAllocation oldReservation) Performs the actual allocation for a ReservationDefinition within a Plan.IterativePlanner.computeJobAllocation(Plan plan, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, String user) abstract RLESparseResourceAllocationPlanningAlgorithm.computeJobAllocation(Plan plan, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation, String user) protected Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> IterativePlanner.computeStageAllocation(Plan plan, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageArrivalTime, long stageDeadline, long period, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> StageAllocator.computeStageAllocation(Plan plan, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageArrival, long stageDeadline, long period, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) Computes the allocation of a stage inside a defined time interval.Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> StageAllocatorGreedy.computeStageAllocation(Plan plan, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageEarliestStart, long stageDeadline, long period, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> StageAllocatorGreedyRLE.computeStageAllocation(Plan plan, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageEarliestStart, long stageDeadline, long period, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) Map<ReservationInterval,org.apache.hadoop.yarn.api.records.Resource> StageAllocatorLowCostAligned.computeStageAllocation(Plan plan, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.ReservationRequest rr, long stageArrival, long stageDeadline, long period, String user, org.apache.hadoop.yarn.api.records.ReservationId oldId) booleanAlignedPlannerWithGreedy.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanGreedyReservationAgent.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanPlanningAlgorithm.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanReservationAgent.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) Create a reservation for the user that abides by the specified contractbooleanTryManyReservationAgents.createReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanAlignedPlannerWithGreedy.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan) booleanGreedyReservationAgent.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan) booleanPlanningAlgorithm.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan) booleanReservationAgent.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan) Delete an user reservationbooleanTryManyReservationAgents.deleteReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan) protected static StageAllocatorLowCostAligned.DurationIntervalStageAllocatorLowCostAligned.getDurationInterval(long startTime, long endTime, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.Resource capacity, RLESparseResourceAllocation netRLERes, org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc, long step, org.apache.hadoop.yarn.api.records.Resource requestedResources) protected static intStageAllocatorLowCostAligned.getDurationIntervalGangsCanFit(long startTime, long endTime, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.Resource capacity, RLESparseResourceAllocation netRLERes, org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc, org.apache.hadoop.yarn.api.records.Resource requestedResources) protected static doubleStageAllocatorLowCostAligned.getDurationIntervalTotalCost(long startTime, long endTime, RLESparseResourceAllocation planLoads, RLESparseResourceAllocation planModifications, org.apache.hadoop.yarn.api.records.Resource capacity, org.apache.hadoop.yarn.util.resource.ResourceCalculator resCalc, long step) protected voidIterativePlanner.initialize(Plan plan, org.apache.hadoop.yarn.api.records.ReservationId reservationId, org.apache.hadoop.yarn.api.records.ReservationDefinition reservation) voidUpdate the existingPlan, by adding/removing/updating existing reservations, and adding a subset of the reservation requests in the contracts parameter.voidSimpleCapacityReplanner.plan(Plan plan, List<org.apache.hadoop.yarn.api.records.ReservationDefinition> contracts) booleanAlignedPlannerWithGreedy.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanGreedyReservationAgent.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanPlanningAlgorithm.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) booleanReservationAgent.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract) Update a reservation for the user that abides by the specified contractbooleanTryManyReservationAgents.updateReservation(org.apache.hadoop.yarn.api.records.ReservationId reservationId, String user, Plan plan, org.apache.hadoop.yarn.api.records.ReservationDefinition contract)