You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ss...@apache.org on 2013/11/25 20:20:12 UTC
git commit: TEZ-641. Fix exit code for MRRSleepJob. (sseth)
Updated Branches:
refs/heads/master 369de6033 -> d2d397aaa
TEZ-641. Fix exit code for MRRSleepJob. (sseth)
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/d2d397aa
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/d2d397aa
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/d2d397aa
Branch: refs/heads/master
Commit: d2d397aaa67b43494cd58024be28dfe54c506835
Parents: 369de60
Author: Siddharth Seth <ss...@apache.org>
Authored: Mon Nov 25 11:19:34 2013 -0800
Committer: Siddharth Seth <ss...@apache.org>
Committed: Mon Nov 25 11:19:34 2013 -0800
----------------------------------------------------------------------
.../main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java | 4 +---
.../java/org/apache/tez/mapreduce/examples/OrderedWordCount.java | 1 -
2 files changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/d2d397aa/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
index b02e87e..095e1b4 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/MRRSleepJob.java
@@ -55,7 +55,6 @@ import org.apache.hadoop.util.ClassUtil;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;
import org.apache.hadoop.yarn.api.records.ApplicationId;
-import org.apache.hadoop.yarn.api.records.FinalApplicationStatus;
import org.apache.hadoop.yarn.api.records.LocalResource;
import org.apache.hadoop.yarn.api.records.LocalResourceType;
import org.apache.hadoop.yarn.api.records.LocalResourceVisibility;
@@ -846,8 +845,7 @@ public class MRRSleepJob extends Configured implements Tool {
}
}
- return dagClient.getApplicationReport().getFinalApplicationStatus() ==
- FinalApplicationStatus.SUCCEEDED ? 0 : 1;
+ return dagClient.getDAGStatus(null).getState().equals(DAGStatus.State.SUCCEEDED) ? 0 : 1;
}
}
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/d2d397aa/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
index 07a80d6..b1448ae 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/OrderedWordCount.java
@@ -20,7 +20,6 @@ package org.apache.tez.mapreduce.examples;
import java.io.IOException;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.List;