You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by ac...@apache.org on 2013/06/19 09:19:35 UTC
git commit: TEZ-261. Deal with changes to YarnClient in YARN-553.
Updated Branches:
refs/heads/master a037d9693 -> c6a36726d
TEZ-261. Deal with changes to YarnClient in YARN-553.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/c6a36726
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/c6a36726
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/c6a36726
Branch: refs/heads/master
Commit: c6a36726dba935d12428ddd008204589ce8c90ad
Parents: a037d96
Author: Arun C. Murthy <ac...@apache.org>
Authored: Wed Jun 19 00:19:15 2013 -0700
Committer: Arun C. Murthy <ac...@apache.org>
Committed: Wed Jun 19 00:19:15 2013 -0700
----------------------------------------------------------------------
tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java | 3 ++-
.../main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/c6a36726/tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java
----------------------------------------------------------------------
diff --git a/tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java b/tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java
index d4208fa..88c14e9 100644
--- a/tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java
+++ b/tez-dag-api/src/main/java/org/apache/tez/client/TezClient.java
@@ -154,7 +154,8 @@ public class TezClient {
*/
public ApplicationId createApplication() throws TezException, IOException {
try {
- return yarnClient.getNewApplication().getApplicationId();
+ return yarnClient.createApplication().
+ getNewApplicationResponse().getApplicationId();
} catch (YarnException e) {
throw new TezException(e);
}
http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/c6a36726/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java
----------------------------------------------------------------------
diff --git a/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java b/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java
index 757675f..e566026 100644
--- a/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java
+++ b/tez-yarn-client/src/main/java/org/apache/tez/mapreduce/ResourceMgrDelegate.java
@@ -118,7 +118,8 @@ public class ResourceMgrDelegate extends YarnClientImpl {
public JobID getNewJobID() throws IOException, InterruptedException {
try {
- this.application = super.getNewApplication();
+ this.application =
+ super.createApplication().getNewApplicationResponse();
} catch (YarnException e) {
throw new IOException(e);
}