You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/07/16 10:49:06 UTC
[08/50] [abbrv] incubator-ignite git commit: #YARN Code cleanup.
#YARN Code cleanup.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/78ab7aa1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/78ab7aa1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/78ab7aa1
Branch: refs/heads/ignite-901
Commit: 78ab7aa1a5f7255b43db129ae3f40093e076cc55
Parents: 7e072dc
Author: nikolay tikhonov <nt...@gridgain.com>
Authored: Wed Jun 10 17:00:05 2015 +0300
Committer: nikolay tikhonov <nt...@gridgain.com>
Committed: Wed Jun 10 17:00:05 2015 +0300
----------------------------------------------------------------------
.../src/main/java/org/apache/ignite/yarn/ApplicationMaster.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/78ab7aa1/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java
----------------------------------------------------------------------
diff --git a/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java b/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java
index 0ef1362..a784340 100644
--- a/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java
+++ b/modules/yarn/src/main/java/org/apache/ignite/yarn/ApplicationMaster.java
@@ -322,6 +322,10 @@ public class ApplicationMaster implements AMRMClientAsync.CallbackHandler {
// Create async application master.
rmClient = AMRMClientAsync.createAMRMClientAsync(300, this);
+ rmClient.init(conf);
+
+ rmClient.start();
+
if (props.igniteCfg() == null || props.igniteCfg().isEmpty()) {
InputStream input = Thread.currentThread().getContextClassLoader()
.getResourceAsStream(IgniteYarnUtils.DEFAULT_IGNITE_CONFIG);