YARN-7636. Re-reservation count may overflow when cluster resource exhausted for a long time. contributed by Tao Yang.
This commit is contained in:
parent
21c6661461
commit
154cfb2b62
|
@ -418,7 +418,11 @@ public class SchedulerApplicationAttempt implements SchedulableEntity {
|
||||||
|
|
||||||
protected void addReReservation(
|
protected void addReReservation(
|
||||||
SchedulerRequestKey schedulerKey) {
|
SchedulerRequestKey schedulerKey) {
|
||||||
reReservations.add(schedulerKey);
|
try {
|
||||||
|
reReservations.add(schedulerKey);
|
||||||
|
} catch (IllegalArgumentException e) {
|
||||||
|
// This happens when count = MAX_INT, ignore the exception
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public int getReReservations(SchedulerRequestKey schedulerKey) {
|
public int getReReservations(SchedulerRequestKey schedulerKey) {
|
||||||
|
@ -1006,8 +1010,13 @@ public class SchedulerApplicationAttempt implements SchedulableEntity {
|
||||||
|
|
||||||
public int addMissedNonPartitionedRequestSchedulingOpportunity(
|
public int addMissedNonPartitionedRequestSchedulingOpportunity(
|
||||||
SchedulerRequestKey schedulerKey) {
|
SchedulerRequestKey schedulerKey) {
|
||||||
return missedNonPartitionedReqSchedulingOpportunity.add(
|
try {
|
||||||
schedulerKey, 1) + 1;
|
return missedNonPartitionedReqSchedulingOpportunity.add(
|
||||||
|
schedulerKey, 1) + 1;
|
||||||
|
} catch (IllegalArgumentException e) {
|
||||||
|
// This happens when count = MAX_INT, ignore the exception
|
||||||
|
return Integer.MAX_VALUE;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void
|
public void
|
||||||
|
|
Loading…
Reference in New Issue