|
@@ -2324,14 +2324,16 @@ class JobInProgress {
|
|
|
private synchronized void terminateJob(int jobTerminationState) {
|
|
|
if ((status.getRunState() == JobStatus.RUNNING) ||
|
|
|
(status.getRunState() == JobStatus.PREP)) {
|
|
|
- // Log the job summary
|
|
|
- JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
|
|
|
-
|
|
|
if (jobTerminationState == JobStatus.FAILED) {
|
|
|
this.status = new JobStatus(status.getJobID(),
|
|
|
1.0f, 1.0f, 1.0f, JobStatus.FAILED,
|
|
|
status.getJobPriority());
|
|
|
this.finishTime = System.currentTimeMillis();
|
|
|
+
|
|
|
+ // Log the job summary
|
|
|
+ JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
|
|
|
+
|
|
|
+ // Log to job-history
|
|
|
JobHistory.JobInfo.logFailed(this.status.getJobID(), finishTime,
|
|
|
this.finishedMapTasks,
|
|
|
this.finishedReduceTasks);
|
|
@@ -2340,6 +2342,11 @@ class JobInProgress {
|
|
|
1.0f, 1.0f, 1.0f, JobStatus.KILLED,
|
|
|
status.getJobPriority());
|
|
|
this.finishTime = System.currentTimeMillis();
|
|
|
+
|
|
|
+ // Log the job summary
|
|
|
+ JobSummary.logJobSummary(this, jobtracker.getClusterStatus(false));
|
|
|
+
|
|
|
+ // Log to job-history
|
|
|
JobHistory.JobInfo.logKilled(this.status.getJobID(), finishTime,
|
|
|
this.finishedMapTasks,
|
|
|
this.finishedReduceTasks);
|