YARN-2450. Fix typos in log messages. Contributed by Ray Chiang.

(cherry picked from commit 3de66011c2)
This commit is contained in:
Hitesh Shah 2014-08-29 11:16:36 -07:00
parent 77a4b014e6
commit aeb8667a06
7 changed files with 12 additions and 10 deletions

View File

@ -235,6 +235,8 @@ Release 2.6.0 - UNRELEASED
is not automatically added when hadoop.http.filter.initializers is not is not automatically added when hadoop.http.filter.initializers is not
configured. (Varun Vasudev via zjshen) configured. (Varun Vasudev via zjshen)
YARN-2450. Fix typos in log messages. (Ray Chiang via hitesh)
Release 2.5.1 - UNRELEASED Release 2.5.1 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

View File

@ -519,7 +519,7 @@ public class ApplicationMaster {
publishApplicationAttemptEvent(timelineClient, appAttemptID.toString(), publishApplicationAttemptEvent(timelineClient, appAttemptID.toString(),
DSEvent.DS_APP_ATTEMPT_START); DSEvent.DS_APP_ATTEMPT_START);
} catch (Exception e) { } catch (Exception e) {
LOG.error("App Attempt start event coud not be pulished for " LOG.error("App Attempt start event could not be published for "
+ appAttemptID.toString(), e); + appAttemptID.toString(), e);
} }
@ -616,7 +616,7 @@ public class ApplicationMaster {
publishApplicationAttemptEvent(timelineClient, appAttemptID.toString(), publishApplicationAttemptEvent(timelineClient, appAttemptID.toString(),
DSEvent.DS_APP_ATTEMPT_END); DSEvent.DS_APP_ATTEMPT_END);
} catch (Exception e) { } catch (Exception e) {
LOG.error("App Attempt start event coud not be pulished for " LOG.error("App Attempt start event could not be published for "
+ appAttemptID.toString(), e); + appAttemptID.toString(), e);
} }
} }
@ -726,7 +726,7 @@ public class ApplicationMaster {
try { try {
publishContainerEndEvent(timelineClient, containerStatus); publishContainerEndEvent(timelineClient, containerStatus);
} catch (Exception e) { } catch (Exception e) {
LOG.error("Container start event could not be pulished for " LOG.error("Container start event could not be published for "
+ containerStatus.getContainerId().toString(), e); + containerStatus.getContainerId().toString(), e);
} }
} }
@ -847,7 +847,7 @@ public class ApplicationMaster {
ApplicationMaster.publishContainerStartEvent( ApplicationMaster.publishContainerStartEvent(
applicationMaster.timelineClient, container); applicationMaster.timelineClient, container);
} catch (Exception e) { } catch (Exception e) {
LOG.error("Container start event coud not be pulished for " LOG.error("Container start event could not be published for "
+ container.getId().toString(), e); + container.getId().toString(), e);
} }
} }

View File

@ -197,7 +197,7 @@ public class Client {
} }
result = client.run(); result = client.run();
} catch (Throwable t) { } catch (Throwable t) {
LOG.fatal("Error running CLient", t); LOG.fatal("Error running Client", t);
System.exit(1); System.exit(1);
} }
if (result) { if (result) {

View File

@ -801,7 +801,7 @@ public class ResourceLocalizationService extends CompositeService
try { try {
Path local = completed.get(); Path local = completed.get();
if (null == assoc) { if (null == assoc) {
LOG.error("Localized unkonwn resource to " + completed); LOG.error("Localized unknown resource to " + completed);
// TODO delete // TODO delete
return; return;
} }
@ -810,7 +810,7 @@ public class ResourceLocalizationService extends CompositeService
.getDU(new File(local.toUri())))); .getDU(new File(local.toUri()))));
assoc.getResource().unlock(); assoc.getResource().unlock();
} catch (ExecutionException e) { } catch (ExecutionException e) {
LOG.info("Failed to download rsrc " + assoc.getResource(), LOG.info("Failed to download resource " + assoc.getResource(),
e.getCause()); e.getCause());
LocalResourceRequest req = assoc.getResource().getRequest(); LocalResourceRequest req = assoc.getResource().getRequest();
publicRsrc.handle(new ResourceFailedLocalizationEvent(req, publicRsrc.handle(new ResourceFailedLocalizationEvent(req,

View File

@ -300,7 +300,7 @@ public class FileSystemRMStateStore extends RMStateStore {
assert appState != null; assert appState != null;
appState.attempts.put(attemptState.getAttemptId(), attemptState); appState.attempts.put(attemptState.getAttemptId(), attemptState);
} }
LOG.info("Done Loading applications from FS state store"); LOG.info("Done loading applications from FS state store");
} catch (Exception e) { } catch (Exception e) {
LOG.error("Failed to load state.", e); LOG.error("Failed to load state.", e);
throw e; throw e;

View File

@ -608,7 +608,7 @@ public class ZKRMStateStore extends RMStateStore {
appState.attempts.put(attemptState.getAttemptId(), attemptState); appState.attempts.put(attemptState.getAttemptId(), attemptState);
} }
} }
LOG.debug("Done Loading applications from ZK state store"); LOG.debug("Done loading applications from ZK state store");
} }
@Override @Override

View File

@ -289,7 +289,7 @@ public class DelegationTokenRenewer extends AbstractService {
tokenWithConf = queue.take(); tokenWithConf = queue.take();
final TokenWithConf current = tokenWithConf; final TokenWithConf current = tokenWithConf;
if (LOG.isDebugEnabled()) { if (LOG.isDebugEnabled()) {
LOG.debug("Canceling token " + tokenWithConf.token.getService()); LOG.debug("Cancelling token " + tokenWithConf.token.getService());
} }
// need to use doAs so that http can find the kerberos tgt // need to use doAs so that http can find the kerberos tgt
UserGroupInformation.getLoginUser() UserGroupInformation.getLoginUser()