Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
 
 package org.apache.hadoop.hbase.master;
 
 import java.io.File;
 import java.util.List;
 
 
 public class HMasterCommandLine extends ServerCommandLine {
   private static final Log LOG = LogFactory.getLog(HMasterCommandLine.class);
 
   private static final String USAGE =
     "Usage: Master [opts] start|stop|clear\n" +
     " start  Start Master. If local mode, start Master and RegionServer in same JVM\n" +
     " stop   Start cluster shutdown; Master signals RegionServer shutdown\n" +
     " clear  Delete the master znode in ZooKeeper after a master crashes\n "+
     " where [opts] are:\n" +
     "   --minRegionServers=<servers>   Minimum RegionServers needed to host user tables.\n" +
     "   --localRegionServers=<servers> " +
       "RegionServers to start in master process when in standalone mode.\n" +
     "   --masters=<servers>            Masters to start in this process.\n" +
     "   --backup                       Master should start in backup mode";
 
   private final Class<? extends HMastermasterClass;
 
   public HMasterCommandLine(Class<? extends HMastermasterClass) {
     this. = masterClass;
   }
 
   protected String getUsage() {
     return ;
   }
 
 
   public int run(String args[]) throws Exception {
     Options opt = new Options();
     opt.addOption("localRegionServers"true,
       "RegionServers to start in master process when running standalone");
     opt.addOption("masters"true"Masters to start in this process");
     opt.addOption("minRegionServers"true"Minimum RegionServers needed to host user tables");
     opt.addOption("backup"false"Do not try to become HMaster until the primary fails");
 
     CommandLine cmd;
     try {
       cmd = new GnuParser().parse(optargs);
     } catch (ParseException e) {
       .error("Could not parse: "e);
       usage(null);
       return 1;
     }
 
 
     if (cmd.hasOption("minRegionServers")) {
       String val = cmd.getOptionValue("minRegionServers");
       getConf().setInt("hbase.regions.server.count.min",
                   Integer.valueOf(val));
       .debug("minRegionServers set to " + val);
     }
 
     // minRegionServers used to be minServers.  Support it too.
    if (cmd.hasOption("minServers")) {
      String val = cmd.getOptionValue("minServers");
      getConf().setInt("hbase.regions.server.count.min",
                  Integer.valueOf(val));
      .debug("minServers set to " + val);
    }
    // check if we are the backup master - override the conf if so
    if (cmd.hasOption("backup")) {
    }
    // How many regionservers to startup in this process (we run regionservers in same process as
    // master when we are in local/standalone mode. Useful testing)
    if (cmd.hasOption("localRegionServers")) {
      String val = cmd.getOptionValue("localRegionServers");
      getConf().setInt("hbase.regionservers", Integer.valueOf(val));
      .debug("localRegionServers set to " + val);
    }
    // How many masters to startup inside this process; useful testing
    if (cmd.hasOption("masters")) {
      String val = cmd.getOptionValue("masters");
      getConf().setInt("hbase.masters", Integer.valueOf(val));
      .debug("masters set to " + val);
    }
    List<StringremainingArgs = cmd.getArgList();
    if (remainingArgs.size() != 1) {
      usage(null);
      return 1;
    }
    String command = remainingArgs.get(0);
    if ("start".equals(command)) {
      return startMaster();
    } else if ("stop".equals(command)) {
      return stopMaster();
    } else if ("clear".equals(command)) {
      return (ZNodeClearer.clear(getConf()) ? 0 : 1);
    } else {
      usage("Invalid command: " + command);
      return 1;
    }
  }
  private int startMaster() {
    Configuration conf = getConf();
    try {
      // If 'local', defer to LocalHBaseCluster instance.  Starts master
      // and regionserver both in the one JVM.
      if (LocalHBaseCluster.isLocal(conf)) {
        final MiniZooKeeperCluster zooKeeperCluster = new MiniZooKeeperCluster(conf);
        File zkDataPath = new File(conf.get(.));
        int zkClientPort = conf.getInt(., 0);
        if (zkClientPort == 0) {
          throw new IOException("No config value for "
              + .);
        }
        zooKeeperCluster.setDefaultClientPort(zkClientPort);
        // login the zookeeper server principal (if using security)
        ZKUtil.loginServer(conf"hbase.zookeeper.server.keytab.file",
          "hbase.zookeeper.server.kerberos.principal"null);
        int clientPort = zooKeeperCluster.startup(zkDataPath);
        if (clientPort != zkClientPort) {
          String errorMsg = "Could not start ZK at requested port of " +
            zkClientPort + ".  ZK was started at port: " + clientPort +
            ".  Aborting as clients (e.g. shell) will not be able to find " +
            "this ZK quorum.";
          ..println(errorMsg);
          throw new IOException(errorMsg);
        }
                 Integer.toString(clientPort));
        int localZKClusterSessionTimeout =
            conf.getInt(. + ".localHBaseCluster", 10*1000);
        conf.setInt(.localZKClusterSessionTimeout);
        // Need to have the zk cluster shutdown when master is shutdown.
        // Run a subclass that does the zk cluster shutdown on its way out.
        LocalHBaseCluster cluster = new LocalHBaseCluster(confconf.getInt("hbase.masters", 1),
          conf.getInt("hbase.regionservers", 1), LocalHMaster.classHRegionServer.class);
        ((LocalHMaster)cluster.getMaster(0)).setZKCluster(zooKeeperCluster);
        cluster.startup();
        waitOnMasterThreads(cluster);
      } else {
        logProcessInfo(getConf());
        HMaster master = HMaster.constructMaster(conf);
        if (master.isStopped()) {
          .info("Won't bring the Master up as a shutdown is requested");
          return 1;
        }
        master.start();
        master.join();
        if(master.isAborted())
          throw new RuntimeException("HMaster Aborted");
      }
    } catch (Throwable t) {
      .error("Master exiting"t);
      return 1;
    }
    return 0;
  }
  private int stopMaster() {
    HBaseAdmin adm = null;
    try {
      Configuration conf = getConf();
      // Don't try more than once
      adm = new HBaseAdmin(getConf());
    } catch (MasterNotRunningException e) {
      .error("Master not running");
      return 1;
    } catch (ZooKeeperConnectionException e) {
      .error("ZooKeeper not available");
      return 1;
    } catch (IOException e) {
      .error("Got IOException: " +e.getMessage(), e);
      return 1;
    }
    try {
      adm.shutdown();
    } catch (Throwable t) {
      .error("Failed to stop master"t);
      return 1;
    }
    return 0;
  }
  private void waitOnMasterThreads(LocalHBaseCluster clusterthrows InterruptedException{
    List<JVMClusterUtil.MasterThreadmasters = cluster.getMasters();
    List<JVMClusterUtil.RegionServerThreadregionservers = cluster.getRegionServers();
    if (masters != null) {
      for (JVMClusterUtil.MasterThread t : masters) {
        t.join();
        if(t.getMaster().isAborted()) {
          closeAllRegionServerThreads(regionservers);
          throw new RuntimeException("HMaster Aborted");
        }
      }
    }
  }
  private static void closeAllRegionServerThreads(List<JVMClusterUtil.RegionServerThreadregionservers) {
    for(JVMClusterUtil.RegionServerThread t : regionservers){
      t.getRegionServer().stop("HMaster Aborted; Bringing down regions servers");
    }
  }
  /*
   * Version of master that will shutdown the passed zk cluster on its way out.
   */
  public static class LocalHMaster extends HMaster {
    private MiniZooKeeperCluster zkcluster = null;
    public LocalHMaster(Configuration conf)
      super(conf);
    }
    @Override
    public void run() {
      super.run();
      if (this. != null) {
        try {
          this..shutdown();
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
    void setZKCluster(final MiniZooKeeperCluster zkcluster) {
      this. = zkcluster;
    }
  }
New to GrepCode? Check out our FAQ X