tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-304. Make MRRSleepJob respect MR AM java opts. (hitesh)
Date Thu, 18 Jul 2013 22:09:35 GMT
Updated Branches:
  refs/heads/master 890b130c2 -> 79e0b7837


TEZ-304. Make MRRSleepJob respect MR AM java opts. (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/79e0b783
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/79e0b783
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/79e0b783

Branch: refs/heads/master
Commit: 79e0b7837b86bd93f1fe5b1997e783e946aa327d
Parents: 890b130
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Jul 18 15:09:12 2013 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Jul 18 15:09:12 2013 -0700

----------------------------------------------------------------------
 .../java/org/apache/tez/mapreduce/examples/MRRSleepJob.java     | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/79e0b783/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 6b9c2b0..6cef99c 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
@@ -727,9 +727,12 @@ public class MRRSleepJob extends Configured implements Tool {
         mapSleepTime, mapSleepCount, reduceSleepTime, reduceSleepCount,
         iReduceSleepTime, iReduceSleepCount);
 
+    List<String> amArgs = new ArrayList<String>();
+    amArgs.add(MRHelpers.getMRAMJavaOpts(conf));
+
     DAGClient dagClient =
         tezClient.submitDAGApplication(appId, dag, remoteStagingDir,
-            null, null, null, null, null, conf);
+            null, null, amArgs , null, null, conf);
 
     while (true) {
       DAGStatus status = dagClient.getDAGStatus();


Mime
View raw message