big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix typos in log messages. Contributed by Ray Chiang

Browse Source
This commit is contained in:
Chris Douglas 2014-08-28 16:29:35 -07:00
parent d9a7404c38
commit 48aa3b7274
6 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-mapreduce-project/CHANGES.txt
View File

@ -252,16 +252,18 @@ Release 2.6.0 - UNRELEASED
(Chen He via jlowe)
BREAKDOWN OF HDFS-6134 AND HADOOP-10150 SUBTASKS AND RELATED JIRAS
MAPREDUCE-5890. Support for encrypting Intermediate
data and spills in local filesystem. (asuresh via tucu)
MAPREDUCE-6007. Add support to distcp to preserve raw.* namespace
extended attributes. (clamb)
MAPREDUCE-6041. Fix TestOptionsParser. (clamb)
--
MAPREDUCE-6051. Fix typos in log messages. (Ray Chiang via cdouglas)
Release 2.5.1 - UNRELEASED
INCOMPATIBLE CHANGES

2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/commit/CommitterEventHandler.java
View File

@ -202,7 +202,7 @@ private synchronized void jobCommitEnded() {
private synchronized void cancelJobCommit() {
Thread threadCommitting = jobCommitThread;
if (threadCommitting != null && threadCommitting.isAlive()) {
LOG.info("Canceling commit");
LOG.info("Cancelling commit");
threadCommitting.interrupt();
// wait up to configured timeout for commit thread to finish

2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/RMCommunicator.java
View File

@ -335,7 +335,7 @@ public void setShouldUnregister(boolean shouldUnregister) {
public void setSignalled(boolean isSignalled) {
this.isSignalled = isSignalled;
LOG.info("RMCommunicator notified that iSignalled is: "
LOG.info("RMCommunicator notified that isSignalled is: "
+ isSignalled);
}

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java
View File

@ -134,16 +134,16 @@ public DefaultSpeculator(Configuration conf, AppContext context, Clock clock) {
estimator.contextualize(conf, context);
} catch (InstantiationException ex) {
LOG.error("Can't make a speculation runtime extimator", ex);
LOG.error("Can't make a speculation runtime estimator", ex);
throw new YarnRuntimeException(ex);
} catch (IllegalAccessException ex) {
LOG.error("Can't make a speculation runtime extimator", ex);
LOG.error("Can't make a speculation runtime estimator", ex);
throw new YarnRuntimeException(ex);
} catch (InvocationTargetException ex) {
LOG.error("Can't make a speculation runtime extimator", ex);
LOG.error("Can't make a speculation runtime estimator", ex);
throw new YarnRuntimeException(ex);
} catch (NoSuchMethodException ex) {
LOG.error("Can't make a speculation runtime extimator", ex);
LOG.error("Can't make a speculation runtime estimator", ex);
throw new YarnRuntimeException(ex);
}

2
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/BackupStore.java
View File

@ -607,7 +607,7 @@ int reserve(int requestedSize) {
int reserve(int requestedSize, int minSize) {
if (availableSize < minSize) {
LOG.debug("No Space available. Available: " + availableSize +
LOG.debug("No space available. Available: " + availableSize +
" MinSize: " + minSize);
return 0;
} else {

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/JHLogAnalyzer.java
View File

@ -1076,7 +1076,7 @@ private static void analyzeResult( FileSystem fs,
long execTime,
Path resFileName
) throws IOException {
LOG.info("Analizing results ...");
LOG.info("Analyzing results ...");
DataOutputStream out = null;
BufferedWriter writer = null;
try {
@ -1118,7 +1118,7 @@ private static void analyzeResult( FileSystem fs,
if(writer != null) writer.close();
if(out != null) out.close();
}
LOG.info("Analizing results ... done.");
LOG.info("Analyzing results ... done.");
}
private static void cleanup(Configuration conf) throws IOException {