YARN-6079. Fix simple spelling errors in yarn test code. Contributed by vijay.
This commit is contained in:
parent
e69231658d
commit
4db119b7b5
@ -247,7 +247,7 @@ public void testAMRMClientNoMatchingRequests()
|
||||
Resource testCapability1 = Resource.newInstance(1024, 2);
|
||||
List<? extends Collection<ContainerRequest>> matches =
|
||||
amClient.getMatchingRequests(priority, node, testCapability1);
|
||||
assertEquals("Expected no macthing requests.", matches.size(), 0);
|
||||
assertEquals("Expected no matching requests.", matches.size(), 0);
|
||||
}
|
||||
|
||||
@Test (timeout=60000)
|
||||
|
@ -222,7 +222,7 @@ private <R> Map<String, GetSetPair> getGetSetPairs(Class<R> recordClass)
|
||||
GetSetPair gsp = cur.getValue();
|
||||
if ((gsp.getMethod == null) ||
|
||||
(gsp.setMethod == null)) {
|
||||
LOG.info(String.format("Exclude protential property: %s\n", gsp.propertyName));
|
||||
LOG.info(String.format("Exclude potential property: %s\n", gsp.propertyName));
|
||||
itr.remove();
|
||||
} else {
|
||||
LOG.info(String.format("New property: %s type: %s", gsp.toString(), gsp.type));
|
||||
|
@ -155,7 +155,7 @@ public void testAddInvalidlabel() throws IOException {
|
||||
} catch (IOException e) {
|
||||
caught = true;
|
||||
}
|
||||
Assert.assertTrue("invalid label charactor should not add to repo", caught);
|
||||
Assert.assertTrue("invalid label character should not add to repo", caught);
|
||||
|
||||
caught = false;
|
||||
try {
|
||||
|
@ -163,7 +163,7 @@ public void testNodeHealthService() throws Exception {
|
||||
LOG.info("Checking Healthy--->timeout");
|
||||
Assert.assertFalse("Node health status reported healthy even after timeout",
|
||||
healthStatus.getIsNodeHealthy());
|
||||
Assert.assertTrue("Node script time out message not propogated",
|
||||
Assert.assertTrue("Node script time out message not propagated",
|
||||
healthStatus.getHealthReport().equals(
|
||||
NodeHealthScriptRunner.NODE_HEALTH_SCRIPT_TIMED_OUT_MSG
|
||||
+ NodeHealthCheckerService.SEPARATOR
|
||||
|
@ -2102,7 +2102,7 @@ rls.new LocalizerRunner(new LocalizerContext(user, container1
|
||||
Assert.assertEquals(userCachePath, destinationDirectory.getParent()
|
||||
.toUri().toString());
|
||||
} else {
|
||||
throw new Exception("Unexpected resource recevied.");
|
||||
throw new Exception("Unexpected resource received.");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
@ -624,7 +624,7 @@ protected Dispatcher createDispatcher() {
|
||||
HAServiceProtocol.RequestSource.REQUEST_BY_USER);
|
||||
FailFastDispatcher dispatcher =
|
||||
((FailFastDispatcher) rm.rmContext.getDispatcher());
|
||||
// Verify transistion to transitionToStandby
|
||||
// Verify transition to transitionToStandby
|
||||
rm.adminService.transitionToStandby(requestInfo);
|
||||
assertEquals("Fatal Event should be 0", 0, dispatcher.getEventCount());
|
||||
assertEquals("HA state should be in standBy State", HAServiceState.STANDBY,
|
||||
@ -632,7 +632,7 @@ protected Dispatcher createDispatcher() {
|
||||
try {
|
||||
// Verify refreshAll call failure and check fail Event is dispatched
|
||||
rm.adminService.transitionToActive(requestInfo);
|
||||
Assert.fail("Transistion to Active should have failed for refreshAll()");
|
||||
Assert.fail("Transition to Active should have failed for refreshAll()");
|
||||
} catch (Exception e) {
|
||||
assertTrue("Service fail Exception expected",
|
||||
e instanceof ServiceFailedException);
|
||||
|
@ -917,7 +917,7 @@ public void testResourceUpdateOnRebootedNode() {
|
||||
|
||||
Assert.assertEquals(NodeState.REBOOTED, node.getState());
|
||||
Assert.assertEquals("Active Nodes", initialActive, cm.getNumActiveNMs());
|
||||
Assert.assertEquals("Unhelathy Nodes", initialUnHealthy,
|
||||
Assert.assertEquals("Unhealthy Nodes", initialUnHealthy,
|
||||
cm.getUnhealthyNMs());
|
||||
Assert.assertEquals("Decommissioning Nodes", initialDecommissioning,
|
||||
cm.getNumDecommissioningNMs());
|
||||
|
@ -827,7 +827,7 @@ public void testDRFUserLimits() throws Exception {
|
||||
assertTrue("Verify user_1 got resources ", queueUser1.getUsed()
|
||||
.getMemorySize() > 0);
|
||||
assertTrue(
|
||||
"Exepected AbsoluteUsedCapacity > 0.95, got: "
|
||||
"Expected AbsoluteUsedCapacity > 0.95, got: "
|
||||
+ b.getAbsoluteUsedCapacity(), b.getAbsoluteUsedCapacity() > 0.95);
|
||||
|
||||
// Verify consumedRatio is based on dominant resources
|
||||
|
@ -268,7 +268,7 @@ public static ClientRMService mockClientRMService(RMContext rmContext) {
|
||||
when(clientRMService.getApplications(any(GetApplicationsRequest.class)))
|
||||
.thenReturn(response);
|
||||
} catch (YarnException e) {
|
||||
Assert.fail("Exception is not expteced.");
|
||||
Assert.fail("Exception is not expected.");
|
||||
}
|
||||
return clientRMService;
|
||||
}
|
||||
|
@ -156,7 +156,7 @@ public void testAppsFinished() throws JSONException, Exception {
|
||||
assertEquals("incorrect number of elements", 1, apps.length());
|
||||
try {
|
||||
apps.getJSONArray("app").getJSONObject(0).getJSONObject("resourceInfo");
|
||||
fail("resourceInfo object shouldnt be available for finished apps");
|
||||
fail("resourceInfo object shouldn't be available for finished apps");
|
||||
} catch (Exception e) {
|
||||
assertTrue("resourceInfo shouldn't be available for finished apps",
|
||||
true);
|
||||
|
Loading…
Reference in New Issue
Block a user