MAPREDUCE-6777. Typos in 4 log messages. Contributed by Mehran Hassani
This commit is contained in:
parent
656b520dc6
commit
fa80972efb
|
@ -232,7 +232,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);
|
||||||
|
|
|
@ -385,7 +385,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());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -1290,7 +1290,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);
|
||||||
}
|
}
|
||||||
|
|
|
@ -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(
|
||||||
|
|
Loading…
Reference in New Issue