YARN-11462. Fix Typo of hadoop-yarn-common. (#5539)
Co-authored-by: Shilun Fan <slfan1989@apache.org> Reviewed-by: He Xiaoqiao <hexiaoqiao@apache.org> Signed-off-by: Shilun Fan <slfan1989@apache.org>
This commit is contained in:
slfan1989
GitHub
parent
7c3d94a032
commit
dd6d0ac510
@ -109,11 +109,11 @@ public ContainerManagementProtocolPBClientImpl(long clientVersion,
|
||||
ProtobufRpcEngine2.class);
|
||||
UserGroupInformation ugi = UserGroupInformation.getCurrentUser();
|
||||
|
||||
int expireIntvl = conf.getInt(NM_COMMAND_TIMEOUT, DEFAULT_COMMAND_TIMEOUT);
|
||||
int expireInterval = conf.getInt(NM_COMMAND_TIMEOUT, DEFAULT_COMMAND_TIMEOUT);
|
||||
proxy =
|
||||
(ContainerManagementProtocolPB) RPC.getProxy(ContainerManagementProtocolPB.class,
|
||||
clientVersion, addr, ugi, conf,
|
||||
NetUtils.getDefaultSocketFactory(conf), expireIntvl);
|
||||
NetUtils.getDefaultSocketFactory(conf), expireInterval);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@ -531,7 +531,7 @@ private void publishWithoutBlockingOnQueue(
|
||||
count++;
|
||||
if (count == numberOfAsyncsToMerge) {
|
||||
// Flush the entities if the number of the async
|
||||
// putEntites merged reaches the desired limit. To avoid
|
||||
// putEntities merged reaches the desired limit. To avoid
|
||||
// collecting multiple entities and delaying for a long
|
||||
// time.
|
||||
entitiesHolder.run();
|
||||
|
||||
@ -62,7 +62,7 @@ public enum StoreType {
|
||||
registerLog(NODE_LABEL_STORE, RemoveClusterLabelOp.OPCODE,
|
||||
RemoveClusterLabelOp.class);
|
||||
|
||||
//NodeAttibute operation
|
||||
//NodeAttribute operation
|
||||
registerLog(NODE_ATTRIBUTE, AddNodeToAttributeLogOp.OPCODE,
|
||||
AddNodeToAttributeLogOp.class);
|
||||
registerLog(NODE_ATTRIBUTE, RemoveNodeToAttributeLogOp.OPCODE,
|
||||
|
||||
@ -44,7 +44,7 @@ public class ClientToAMTokenIdentifier extends TokenIdentifier {
|
||||
private ClientToAMTokenIdentifierProto proto;
|
||||
|
||||
// TODO: Add more information in the tokenID such that it is not
|
||||
// transferrable, more secure etc.
|
||||
// transferable, more secure etc.
|
||||
|
||||
public ClientToAMTokenIdentifier() {
|
||||
}
|
||||
|
||||
@ -29,7 +29,7 @@
|
||||
.RemoveFromClusterNodeLabelsRequest;
|
||||
|
||||
/**
|
||||
* Proto class to handlde RemoveFromClusterNodeLabels request.
|
||||
* Proto class to handle RemoveFromClusterNodeLabels request.
|
||||
*/
|
||||
public class RemoveFromClusterNodeLabelsRequestPBImpl
|
||||
extends RemoveFromClusterNodeLabelsRequest {
|
||||
|
||||
@ -252,7 +252,7 @@ private void prepareToExit() {
|
||||
checkState(devMode, "only in dev mode");
|
||||
new Timer("webapp exit", true).schedule(new TimerTask() {
|
||||
@Override public void run() {
|
||||
LOG.info("WebAppp /{} exiting...", webApp.name());
|
||||
LOG.info("WebApp /{} exiting...", webApp.name());
|
||||
webApp.stop();
|
||||
System.exit(0); // FINDBUG: this is intended in dev mode
|
||||
}
|
||||
|
||||
@ -53,7 +53,7 @@ public class GenericExceptionHandler implements ExceptionMapper<Exception> {
|
||||
@Override
|
||||
public Response toResponse(Exception e) {
|
||||
if (LOG.isTraceEnabled()) {
|
||||
LOG.trace("GOT EXCEPITION", e);
|
||||
LOG.trace("GOT EXCEPTION", e);
|
||||
}
|
||||
// Don't catch this as filter forward on 404
|
||||
// (ServletContainer.FEATURE_FILTER_FORWARD_ON_404)
|
||||
|
||||
@ -88,7 +88,7 @@ public void render() {
|
||||
}
|
||||
|
||||
/**
|
||||
* Render the the HTML page.
|
||||
* Render the HTML page.
|
||||
* @param html the page to render data to.
|
||||
*/
|
||||
protected abstract void render(Page.HTML<__> html);
|
||||
|
||||
@ -150,7 +150,7 @@ private static Object genTypeValue(Type type) {
|
||||
}
|
||||
|
||||
/**
|
||||
* this method generate record instance by calling newIntance
|
||||
* this method generate record instance by calling newInstance
|
||||
* using reflection, add register the generated value to typeValueCache
|
||||
*/
|
||||
@SuppressWarnings("rawtypes")
|
||||
|
||||
@ -49,7 +49,7 @@ void testDeserialize() throws Exception {
|
||||
|
||||
try {
|
||||
pb.deSerialize();
|
||||
fail("deSerialze should throw YarnRuntimeException");
|
||||
fail("deSerialize should throw YarnRuntimeException");
|
||||
} catch (YarnRuntimeException e) {
|
||||
assertEquals(ClassNotFoundException.class,
|
||||
e.getCause().getClass());
|
||||
|
||||
@ -439,7 +439,7 @@ private static TimelineEntity generateEntity() {
|
||||
|
||||
public static TimelineDomain generateDomain() {
|
||||
TimelineDomain domain = new TimelineDomain();
|
||||
domain.setId("namesapce id");
|
||||
domain.setId("namespace id");
|
||||
domain.setDescription("domain description");
|
||||
domain.setOwner("domain owner");
|
||||
domain.setReaders("domain_reader");
|
||||
|
||||
@ -238,7 +238,7 @@ private static TimelineEntity generateEntity(String type) {
|
||||
|
||||
private static TimelineDomain generateDomain() {
|
||||
TimelineDomain domain = new TimelineDomain();
|
||||
domain.setId("namesapce id");
|
||||
domain.setId("namespace id");
|
||||
domain.setDescription("domain description");
|
||||
domain.setOwner("domain owner");
|
||||
domain.setReaders("domain_reader");
|
||||
|
||||
@ -241,7 +241,7 @@ void testASyncCallMerge() throws Exception {
|
||||
@Test
|
||||
void testSyncCall() throws Exception {
|
||||
try {
|
||||
// sync entity should not be be merged with Async
|
||||
// sync entity should not be merged with Async
|
||||
client.putEntities(generateEntity("1"));
|
||||
client.putEntitiesAsync(generateEntity("2"));
|
||||
client.putEntitiesAsync(generateEntity("3"));
|
||||
@ -360,7 +360,7 @@ void testSetTimelineToken() throws Exception {
|
||||
new byte[0], "kind", new byte[0], "service");
|
||||
client.setTimelineCollectorInfo(CollectorInfo.newInstance(null, token));
|
||||
assertNull(client.currentTimelineToken,
|
||||
"Timeline token in v2 client should not be set as token kind " + "is unexepcted.");
|
||||
"Timeline token in v2 client should not be set as token kind " + "is unexpected.");
|
||||
assertEquals(0, ugi.getTokens().size());
|
||||
|
||||
token = Token.newInstance(new byte[0], TimelineDelegationTokenIdentifier.
|
||||
|
||||
@ -36,7 +36,7 @@ public class TestYarnConfiguration {
|
||||
void testDefaultRMWebUrl() throws Exception {
|
||||
YarnConfiguration conf = new YarnConfiguration();
|
||||
String rmWebUrl = WebAppUtils.getRMWebAppURLWithScheme(conf);
|
||||
// shouldn't have a "/" on the end of the url as all the other uri routinnes
|
||||
// shouldn't have a "/" on the end of the url as all the other uri routines
|
||||
// specifically add slashes and Jetty doesn't handle double slashes.
|
||||
assertNotSame("http://0.0.0.0:8088",
|
||||
rmWebUrl,
|
||||
@ -77,7 +77,7 @@ void testRMWebUrlSpecified() throws Exception {
|
||||
String[] parts = rmWebUrl.split(":");
|
||||
assertEquals(24543,
|
||||
Integer.parseInt(parts[parts.length - 1]),
|
||||
"RM Web URL Port is incrrect");
|
||||
"RM Web URL Port is incorrect");
|
||||
assertNotSame("http://rmtesting:24543", rmWebUrl,
|
||||
"RM Web Url not resolved correctly. Should not be rmtesting");
|
||||
}
|
||||
|
||||
@ -385,7 +385,7 @@ public boolean isRollover(final FileContext fc, final Path candidate) throws IOE
|
||||
|
||||
@Test
|
||||
@Timeout(15000)
|
||||
void testFetchApplictionLogsHar() throws Exception {
|
||||
void testFetchApplicationLogsHar() throws Exception {
|
||||
List<String> newLogTypes = new ArrayList<>();
|
||||
newLogTypes.add("syslog");
|
||||
newLogTypes.add("stdout");
|
||||
|
||||
@ -143,7 +143,7 @@ void testRecoverWithMirror(String className) throws Exception {
|
||||
"p4", toSet(toNodeId("n4")),
|
||||
"p2", toSet(toNodeId("n2"))));
|
||||
|
||||
// stutdown mgr and start a new mgr
|
||||
// shutdown mgr and start a new mgr
|
||||
mgr.stop();
|
||||
mgr = new MockNodeLabelManager();
|
||||
mgr.init(conf);
|
||||
|
||||
Loading…
Reference in New Issue
Block a user