tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-976. WordCount example does not handle -D<param> args. (Tassapol Athiapinya via hitesh)
Date Wed, 26 Mar 2014 17:56:30 GMT
Repository: incubator-tez
Updated Branches:
  refs/heads/master ba97f7f35 -> f31aba7bc


TEZ-976. WordCount example does not handle -D<param> args. (Tassapol Athiapinya via
hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/f31aba7b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/f31aba7b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/f31aba7b

Branch: refs/heads/master
Commit: f31aba7bca4ff85dec69a4ac949c37e24f7eed1e
Parents: ba97f7f
Author: Hitesh Shah <hitesh@apache.org>
Authored: Tue Mar 25 15:52:03 2014 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Tue Mar 25 15:52:03 2014 -0700

----------------------------------------------------------------------
 .../java/org/apache/tez/mapreduce/examples/WordCount.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/f31aba7b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java
----------------------------------------------------------------------
diff --git a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java
b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java
index de4cc6c..b1cede3 100644
--- a/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java
+++ b/tez-mapreduce-examples/src/main/java/org/apache/tez/mapreduce/examples/WordCount.java
@@ -41,6 +41,7 @@ import org.apache.hadoop.mapreduce.security.TokenCache;
 import org.apache.hadoop.mapreduce.split.TezGroupedSplitsInputFormat;
 import org.apache.hadoop.security.Credentials;
 import org.apache.hadoop.security.UserGroupInformation;
+import org.apache.hadoop.util.GenericOptionsParser;
 import org.apache.hadoop.yarn.api.records.ApplicationId;
 import org.apache.hadoop.yarn.api.records.LocalResource;
 import org.apache.tez.client.AMConfiguration;
@@ -396,12 +397,15 @@ public class WordCount {
   }
 
   public static void main(String[] args) throws Exception {
-    if ((args.length%2) != 0) {
+    Configuration conf = new Configuration();
+    String [] otherArgs = new GenericOptionsParser(conf, args).getRemainingArgs();
+
+    if (otherArgs.length != 2) {
       printUsage();
       System.exit(2);
     }
     WordCount job = new WordCount();
-    job.run(args[0], args[1], null);
+    job.run(otherArgs[0], otherArgs[1], conf);
   }
 
 }


Mime
View raw message