Updated Branches: refs/heads/helix-provisioning 26502e84c -> 180aafe5b
More changes for Yarn integration Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/180aafe5 Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/180aafe5 Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/180aafe5 Branch: refs/heads/helix-provisioning Commit: 180aafe5bb69ff1bf65768646430063a6f7e1823 Parents: 26502e8 Author: Kishore Gopalakrishna <[email protected]> Authored: Wed Jan 8 15:20:55 2014 -0800 Committer: Kishore Gopalakrishna <[email protected]> Committed: Wed Jan 8 15:20:55 2014 -0800 ---------------------------------------------------------------------- .../yarn/HelixYarnApplicationMasterMain.java | 61 ++++++++++++++++++++ 1 file changed, 61 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/180aafe5/helix-provisioning/src/main/java/org/apache/helix/provisioning/yarn/HelixYarnApplicationMasterMain.java ---------------------------------------------------------------------- diff --git a/helix-provisioning/src/main/java/org/apache/helix/provisioning/yarn/HelixYarnApplicationMasterMain.java b/helix-provisioning/src/main/java/org/apache/helix/provisioning/yarn/HelixYarnApplicationMasterMain.java new file mode 100644 index 0000000..73c0e90 --- /dev/null +++ b/helix-provisioning/src/main/java/org/apache/helix/provisioning/yarn/HelixYarnApplicationMasterMain.java @@ -0,0 +1,61 @@ +package org.apache.helix.provisioning.yarn; + +import java.io.IOException; +import java.util.Map; + +import org.I0Itec.zkclient.IDefaultNameSpace; +import org.I0Itec.zkclient.ZkClient; +import org.I0Itec.zkclient.ZkServer; +import org.apache.commons.cli.ParseException; +import org.apache.hadoop.yarn.api.ApplicationConstants.Environment; +import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; +import org.apache.hadoop.yarn.api.records.ContainerId; +import org.apache.hadoop.yarn.exceptions.YarnException; +import org.apache.hadoop.yarn.util.ConverterUtils; + +/** + * This will <br/> + * <ul> + * <li>start zookeeper automatically</li> + * <li>create the cluster</li> + * <li>set up resource(s)</li> + * <li>start helix controller</li> + * </ul> + */ +public class HelixYarnApplicationMasterMain { + public static void main(String[] args) throws Exception { + // START ZOOKEEPER + String dataDir = "dataDir"; + String logDir = "logDir"; + IDefaultNameSpace defaultNameSpace = new IDefaultNameSpace() { + + @Override + public void createDefaultNameSpace(ZkClient zkClient) { + + } + }; + ZkServer server = new ZkServer(dataDir, logDir, defaultNameSpace); + server.start(); + + + + // start + + Map<String, String> envs = System.getenv(); + + ContainerId containerId = + ConverterUtils.toContainerId(envs.get(Environment.CONTAINER_ID.name())); + ApplicationAttemptId appAttemptID = containerId.getApplicationAttemptId(); + + //GenericApplicationMaster genAppMaster = new GenericApplicationMaster(appAttemptID); + + GenericApplicationMaster genericApplicationMaster = new GenericApplicationMaster(appAttemptID); + genericApplicationMaster.start(); + + YarnProvisioner.applicationMaster = genericApplicationMaster; + + // CREATE CLUSTER and setup the resources + + + } +}
