浏览代码

MAPREDUCE-6777. Typos in 4 log messages. Contributed by Mehran Hassani

Naganarasimha 8 年之前
父节点
当前提交
7d21c280a8

+ 1 - 1
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/TaskAttemptListenerImpl.java

@@ -260,7 +260,7 @@ public class TaskAttemptListenerImpl extends CompositeService
 
 
   @Override
   @Override
   public void done(TaskAttemptID taskAttemptID) throws IOException {
   public void done(TaskAttemptID taskAttemptID) throws IOException {
-    LOG.info("Done acknowledgement from " + taskAttemptID.toString());
+    LOG.info("Done acknowledgment from " + taskAttemptID.toString());
 
 
     org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID =
     org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptId attemptID =
         TypeConverter.toYarn(taskAttemptID);
         TypeConverter.toYarn(taskAttemptID);

+ 1 - 1
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryEventHandler.java

@@ -400,7 +400,7 @@ public class JobHistoryEventHandler extends AbstractService
         }
         }
         mi.shutDownTimer();
         mi.shutDownTimer();
       } catch (IOException e) {
       } catch (IOException e) {
-        LOG.info("Exception while cancelling delayed flush timer. "
+        LOG.info("Exception while canceling delayed flush timer. "
             + "Likely caused by a failed flush " + e.getMessage());
             + "Likely caused by a failed flush " + e.getMessage());
       }
       }
     }
     }

+ 1 - 1
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Task.java

@@ -1312,7 +1312,7 @@ abstract public class Task implements Writable, Configurable {
     setPhase(TaskStatus.Phase.CLEANUP);
     setPhase(TaskStatus.Phase.CLEANUP);
     getProgress().setStatus("cleanup");
     getProgress().setStatus("cleanup");
     statusUpdate(umbilical);
     statusUpdate(umbilical);
-    LOG.info("Runnning cleanup for the task");
+    LOG.info("Running cleanup for the task");
     // do the cleanup
     // do the cleanup
     committer.abortTask(taskContext);
     committer.abortTask(taskContext);
   }
   }

+ 1 - 1
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-shuffle/src/main/java/org/apache/hadoop/mapred/ShuffleHandler.java

@@ -672,7 +672,7 @@ public class ShuffleHandler extends AuxiliaryService {
       return;
       return;
     }
     }
     if (loadedVersion.isCompatibleTo(getCurrentVersion())) {
     if (loadedVersion.isCompatibleTo(getCurrentVersion())) {
-      LOG.info("Storing state DB schedma version info " + getCurrentVersion());
+      LOG.info("Storing state DB schema version info " + getCurrentVersion());
       storeVersion();
       storeVersion();
     } else {
     } else {
       throw new IOException(
       throw new IOException(