#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-1.3 Commit: 78ab7aa1a5f7255b43db129ae3f40093e076cc55 Parents: 7e072dc Author: nikolay tikhonov <ntikho...@gridgain.com> Authored: Wed Jun 10 17:00:05 2015 +0300 Committer: nikolay tikhonov <ntikho...@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);
