YARN-5962. Spelling errors in logging and exceptions for resource manager code (gsohn via rkanter)
(cherry picked from commit 1bbd023275
)
This commit is contained in:
parent
10a154cedd
commit
8fbd36c60f
|
@ -408,7 +408,7 @@ public class ClientRMService extends AbstractService implements
|
|||
response = GetApplicationAttemptReportResponse.newInstance(attemptReport);
|
||||
}else{
|
||||
throw new YarnException("User " + callerUGI.getShortUserName()
|
||||
+ " does not have privilage to see this attempt " + appAttemptId);
|
||||
+ " does not have privilege to see this attempt " + appAttemptId);
|
||||
}
|
||||
return response;
|
||||
}
|
||||
|
@ -448,7 +448,7 @@ public class ClientRMService extends AbstractService implements
|
|||
response = GetApplicationAttemptsResponse.newInstance(listAttempts);
|
||||
} else {
|
||||
throw new YarnException("User " + callerUGI.getShortUserName()
|
||||
+ " does not have privilage to see this application " + appId);
|
||||
+ " does not have privilege to see this application " + appId);
|
||||
}
|
||||
return response;
|
||||
}
|
||||
|
@ -499,7 +499,7 @@ public class ClientRMService extends AbstractService implements
|
|||
.createContainerReport());
|
||||
} else {
|
||||
throw new YarnException("User " + callerUGI.getShortUserName()
|
||||
+ " does not have privilage to see this application " + appId);
|
||||
+ " does not have privilege to see this application " + appId);
|
||||
}
|
||||
return response;
|
||||
}
|
||||
|
@ -552,7 +552,7 @@ public class ClientRMService extends AbstractService implements
|
|||
response = GetContainersResponse.newInstance(listContainers);
|
||||
} else {
|
||||
throw new YarnException("User " + callerUGI.getShortUserName()
|
||||
+ " does not have privilage to see this application " + appId);
|
||||
+ " does not have privilege to see this application " + appId);
|
||||
}
|
||||
return response;
|
||||
}
|
||||
|
|
|
@ -162,7 +162,7 @@ public class MemoryRMStateStore extends RMStateStore {
|
|||
ApplicationStateData removed = state.appState.remove(appId);
|
||||
|
||||
if (removed == null) {
|
||||
throw new YarnRuntimeException("Removing non-exsisting application state");
|
||||
throw new YarnRuntimeException("Removing non-existing application state");
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -263,7 +263,7 @@ public class InMemoryPlan implements Plan {
|
|||
reservationTable.put(inMemReservation.getReservationId(),
|
||||
inMemReservation);
|
||||
incrementAllocation(inMemReservation);
|
||||
LOG.info("Sucessfully added reservation: {} to plan.",
|
||||
LOG.info("Successfully added reservation: {} to plan.",
|
||||
inMemReservation.getReservationId());
|
||||
return true;
|
||||
} finally {
|
||||
|
@ -301,7 +301,7 @@ public class InMemoryPlan implements Plan {
|
|||
reservation.getReservationId(), e.getMessage());
|
||||
}
|
||||
if (result) {
|
||||
LOG.info("Sucessfully updated reservation: {} in plan.",
|
||||
LOG.info("Successfully updated reservation: {} in plan.",
|
||||
reservation.getReservationId());
|
||||
return result;
|
||||
} else {
|
||||
|
|
|
@ -148,7 +148,7 @@ public class ReservationInputValidator {
|
|||
plan.getTotalCapacity(), maxGangSize, plan.getTotalCapacity())
|
||||
&& type != ReservationRequestInterpreter.R_ANY) {
|
||||
message =
|
||||
"The size of the largest gang in the reservation refinition ("
|
||||
"The size of the largest gang in the reservation definition ("
|
||||
+ maxGangSize + ") exceed the capacity available ("
|
||||
+ plan.getTotalCapacity() + " )";
|
||||
RMAuditLogger.logFailure("UNKNOWN", auditConstant,
|
||||
|
|
|
@ -719,7 +719,7 @@ public class RMNodeImpl implements RMNode, EventHandler<RMNodeEvent> {
|
|||
metrics.decrDecommissioningNMs();
|
||||
break;
|
||||
default :
|
||||
LOG.warn("Unexpcted initial state");
|
||||
LOG.warn("Unexpected initial state");
|
||||
}
|
||||
|
||||
switch (finalState) {
|
||||
|
|
|
@ -265,7 +265,7 @@ public class SchedulerUtils {
|
|||
// we don't allow specify label expression with more than one node labels now
|
||||
if (labelExp != null && labelExp.contains("&&")) {
|
||||
throw new InvalidLabelResourceRequestException(
|
||||
"Invailid resource request, queue=" + queueInfo.getQueueName()
|
||||
"Invalid resource request, queue=" + queueInfo.getQueueName()
|
||||
+ " specified more than one node label "
|
||||
+ "in a node label expression, node label expression = "
|
||||
+ labelExp);
|
||||
|
|
|
@ -199,7 +199,7 @@ public class RegularContainerAllocator extends AbstractContainerAllocator {
|
|||
LOG.debug("Skip app_attempt=" + application.getApplicationAttemptId()
|
||||
+ " priority=" + schedulerKey.getPriority()
|
||||
+ " because missed-non-partitioned-resource-request"
|
||||
+ " opportunity under requred:" + " Now="
|
||||
+ " opportunity under required:" + " Now="
|
||||
+ missedNonPartitionedRequestSchedulingOpportunity + " required="
|
||||
+ rmContext.getScheduler().getNumClusterNodes());
|
||||
}
|
||||
|
|
|
@ -330,7 +330,7 @@ public class FifoScheduler extends
|
|||
FifoAppAttempt application = getApplicationAttempt(applicationAttemptId);
|
||||
if (application == null) {
|
||||
LOG.error("Calling allocate on removed " +
|
||||
"or non existant application " + applicationAttemptId);
|
||||
"or non-existent application " + applicationAttemptId);
|
||||
return EMPTY_ALLOCATION;
|
||||
}
|
||||
|
||||
|
|
|
@ -368,7 +368,7 @@ class CapacitySchedulerPage extends RmView {
|
|||
.append(" }).fail(function(data){")
|
||||
.append(
|
||||
" alert(\"Scheduler log generation failed. Please check the"
|
||||
+ " ResourceManager log for more informtion.\");")
|
||||
+ " ResourceManager log for more information.\");")
|
||||
.append(" console.log(data);").append(" });").append(" }")
|
||||
.append("}");
|
||||
|
||||
|
|
|
@ -123,7 +123,7 @@ public class TestContainerResourceUsage {
|
|||
AggregateAppResourceUsage ru = calculateContainerResourceMetrics(rmContainer);
|
||||
rmAppMetrics = app0.getRMAppMetrics();
|
||||
|
||||
Assert.assertEquals("Unexcpected MemorySeconds value",
|
||||
Assert.assertEquals("Unexpected MemorySeconds value",
|
||||
ru.getMemorySeconds(), rmAppMetrics.getMemorySeconds());
|
||||
Assert.assertEquals("Unexpected VcoreSeconds value",
|
||||
ru.getVcoreSeconds(), rmAppMetrics.getVcoreSeconds());
|
||||
|
@ -223,7 +223,7 @@ public class TestContainerResourceUsage {
|
|||
}
|
||||
|
||||
RMAppMetrics metricsBefore = app0.getRMAppMetrics();
|
||||
Assert.assertEquals("Unexcpected MemorySeconds value",
|
||||
Assert.assertEquals("Unexpected MemorySeconds value",
|
||||
memorySeconds, metricsBefore.getMemorySeconds());
|
||||
Assert.assertEquals("Unexpected VcoreSeconds value",
|
||||
vcoreSeconds, metricsBefore.getVcoreSeconds());
|
||||
|
@ -392,7 +392,7 @@ public class TestContainerResourceUsage {
|
|||
|
||||
RMAppMetrics rmAppMetrics = app.getRMAppMetrics();
|
||||
|
||||
Assert.assertEquals("Unexcpected MemorySeconds value",
|
||||
Assert.assertEquals("Unexpected MemorySeconds value",
|
||||
memorySeconds, rmAppMetrics.getMemorySeconds());
|
||||
Assert.assertEquals("Unexpected VcoreSeconds value",
|
||||
vcoreSeconds, rmAppMetrics.getVcoreSeconds());
|
||||
|
@ -426,4 +426,4 @@ public class TestContainerResourceUsage {
|
|||
* usedMillis / DateUtils.MILLIS_PER_SECOND;
|
||||
return new AggregateAppResourceUsage(memorySeconds, vcoreSeconds);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
@ -261,10 +261,10 @@ public class TestReservationInputValidator {
|
|||
} catch (YarnException e) {
|
||||
Assert.assertNull(plan);
|
||||
String message = e.getMessage();
|
||||
Assert
|
||||
.assertTrue(message
|
||||
.startsWith("The size of the largest gang in the reservation refinition"));
|
||||
Assert.assertTrue(message.contains("exceed the capacity available "));
|
||||
Assert.assertTrue(message.startsWith(
|
||||
"The size of the largest gang in the reservation definition"));
|
||||
Assert.assertTrue(message.contains(
|
||||
"exceed the capacity available "));
|
||||
LOG.info(message);
|
||||
}
|
||||
}
|
||||
|
@ -493,10 +493,10 @@ public class TestReservationInputValidator {
|
|||
} catch (YarnException e) {
|
||||
Assert.assertNull(plan);
|
||||
String message = e.getMessage();
|
||||
Assert
|
||||
.assertTrue(message
|
||||
.startsWith("The size of the largest gang in the reservation refinition"));
|
||||
Assert.assertTrue(message.contains("exceed the capacity available "));
|
||||
Assert.assertTrue(message.startsWith(
|
||||
"The size of the largest gang in the reservation definition"));
|
||||
Assert.assertTrue(message.contains(
|
||||
"exceed the capacity available "));
|
||||
LOG.info(message);
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue