hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jdcry...@apache.org
Subject svn commit: r781099 - in /hadoop/hbase/trunk: ./ conf/ src/java/ src/java/org/apache/hadoop/hbase/ src/java/org/apache/hadoop/hbase/master/ src/java/org/apache/hadoop/hbase/zookeeper/ src/test/org/apache/hadoop/hbase/
Date Tue, 02 Jun 2009 17:52:32 GMT
Author: jdcryans
Date: Tue Jun  2 17:52:32 2009
New Revision: 781099

URL: http://svn.apache.org/viewvc?rev=781099&view=rev
Log:
HBASE-1357  If one sets the hbase.master to 0.0.0.0 non local regionservers
            can't find the master
HBASE-1445  Add the ability to start a master from any machine


Modified:
    hadoop/hbase/trunk/CHANGES.txt
    hadoop/hbase/trunk/conf/hbase-default.xml
    hadoop/hbase/trunk/conf/zoo.cfg
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/HConstants.java
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/LocalHBaseCluster.java
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/HMaster.java
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/ServerManager.java
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java
    hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java
    hadoop/hbase/trunk/src/java/overview.html
    hadoop/hbase/trunk/src/test/org/apache/hadoop/hbase/PerformanceEvaluation.java

Modified: hadoop/hbase/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/CHANGES.txt?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/CHANGES.txt (original)
+++ hadoop/hbase/trunk/CHANGES.txt Tue Jun  2 17:52:32 2009
@@ -19,6 +19,8 @@
    HBASE-1367  Get rid of Thrift exception 'NotFound'
    HBASE-1381  Remove onelab and bloom filters files from hbase
    HBASE-1411  Remove HLogEdit.
+   HBASE-1357  If one sets the hbase.master to 0.0.0.0 non local regionservers
+               can't find the master
 
   BUG FIXES
    HBASE-1140  "ant clean test" fails (Nitay Joffe via Stack)
@@ -297,6 +299,7 @@
    HBASE-1464  Add hbase.regionserver.logroll.period to hbase-default
    HBASE-1192  LRU-style map for the block cache (Jon Gray and Ryan Rawson
                via Stack)
+   HBASE-1445  Add the ability to start a master from any machine
 
   OPTIMIZATIONS
    HBASE-1412  Change values for delete column and column family in KeyValue

Modified: hadoop/hbase/trunk/conf/hbase-default.xml
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/conf/hbase-default.xml?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/conf/hbase-default.xml (original)
+++ hadoop/hbase/trunk/conf/hbase-default.xml Tue Jun  2 17:52:32 2009
@@ -31,18 +31,19 @@
     </description>
   </property>
   <property>
-    <name>hbase.master.hostname</name>
-    <value>local</value>
-    <description>The host that the HBase master runs at.
-      A value of 'local' runs the master and regionserver in a single process.
-    </description>
-  </property>
-  <property>
     <name>hbase.master.port</name>
     <value>60000</value>
     <description>The port master should bind to.</description>
   </property>
   <property>
+    <name>hbase.cluster.distributed</name>
+    <value>false</value>
+    <description>The mode the cluster will be in. Possible values are
+      false: standalone and pseudo-distributed setups with managed Zookeeper
+      true: fully-distributed with unmanaged Zookeeper Quorum (see hbase-env.sh)
+    </description>
+  </property>
+  <property>
     <name>hbase.tmp.dir</name>
     <value>/tmp/hbase-${user.name}</value>
     <description>Temporary directory on the local filesystem.</description>
@@ -214,6 +215,21 @@
     </description>
   </property>
   <property>
+    <name>hbase.master.dns.interface</name>
+    <value>default</value>
+    <description>The name of the Network Interface from which a master 
+      should report its IP address.
+    </description>
+  </property>
+  <property>
+    <name>hbase.master.dns.nameserver</name>
+    <value>default</value>
+    <description>The host name or IP address of the name server (DNS)
+      which a master should use to determine the host name used 
+      for communication and display purposes.
+    </description>
+  </property>
+  <property>
     <name>hbase.regionserver.globalMemcache.upperLimit</name>
     <value>0.4</value>
     <description>Maximum size of all memcaches in a region server before new 

Modified: hadoop/hbase/trunk/conf/zoo.cfg
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/conf/zoo.cfg?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/conf/zoo.cfg (original)
+++ hadoop/hbase/trunk/conf/zoo.cfg Tue Jun  2 17:52:32 2009
@@ -11,4 +11,4 @@
 # the port at which the clients will connect
 clientPort=2181
 
-server.0=${hbase.master.hostname}:2888:3888
\ No newline at end of file
+server.0=localhost:2888:3888

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/HConstants.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/HConstants.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/HConstants.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/HConstants.java Tue Jun  2 17:52:32
2009
@@ -52,21 +52,16 @@
   
   // Configuration parameters
   
-  // TODO: URL for hbase master like hdfs URLs with host and port.
-  // Like jdbc URLs?  URLs could be used to refer to table cells?
-  // jdbc:mysql://[host][,failoverhost...][:port]/[database]
-  // jdbc:mysql://[host][,failoverhost...][:port]/[database][?propertyName1][=propertyValue1][&propertyName2][=propertyValue2]...
-  
-  // Key into HBaseConfiguration for the hbase.master address.
-  // TODO: Support 'local': i.e. default of all running in single
-  // process.  Same for regionserver. TODO: Is having HBase homed
-  // on port 60k OK?
+  //TODO: Is having HBase homed on port 60k OK?
   
-  /** Parameter name for master address */
-  static final String MASTER_ADDRESS = "hbase.master";
-
-  /** Parameter name for master host name. */
-  static final String MASTER_HOST_NAME = "hbase.master.hostname";
+  /** Cluster is in distributed mode or not */
+  static final String CLUSTER_DISTRIBUTED = "hbase.cluster.distributed";
+  
+  /** Cluster is standalone or pseudo-distributed */
+  static final String CLUSTER_IS_LOCAL = "false";
+  
+  /** Cluster is fully-distributed */
+  static final String CLUSTER_IS_DISTRIBUTED = "true";
 
   /** default host address */
   static final String DEFAULT_HOST = "0.0.0.0";

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/LocalHBaseCluster.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/LocalHBaseCluster.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/LocalHBaseCluster.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/LocalHBaseCluster.java Tue Jun  2
17:52:32 2009
@@ -90,7 +90,6 @@
     final int noRegionServers)
   throws IOException {
     this.conf = conf;
-    doLocal(conf);
     // Create the master
     this.master = new HMaster(conf);
     // Start the HRegionServers.  Always have region servers come up on
@@ -317,46 +316,12 @@
   }
 
   /**
-   * Changes <code>hbase.master</code> from 'local' to 'localhost:PORT' in
-   * passed Configuration instance.
-   * @param c
-   * @return The passed <code>c</code> configuration modified if hbase.master
-   * value was 'local' otherwise, unaltered.
-   */
-  private static HBaseConfiguration doLocal(final HBaseConfiguration c) {
-    if (!isLocal(c)) {
-      return c;
-    }
-
-    // Need to rewrite address in Configuration if not done already.
-    String address = c.get(MASTER_ADDRESS);
-    if (address != null) {
-      String port = address.startsWith(LOCAL_COLON)?
-        address.substring(LOCAL_COLON.length()):
-        Integer.toString(DEFAULT_MASTER_PORT);
-      c.set(MASTER_ADDRESS, "localhost:" + port);
-    }
-
-    // Need to rewrite host in Configuration if not done already.
-    String host = c.get(MASTER_HOST_NAME);
-    if (host != null && host.equals(LOCAL)) {
-      c.set(MASTER_HOST_NAME, "localhost");
-    }
-
-    return c;
-  }
-
-  /**
    * @param c Configuration to check.
    * @return True if a 'local' address in hbase.master value.
    */
   public static boolean isLocal(final Configuration c) {
-    String address = c.get(MASTER_ADDRESS);
-    boolean addressIsLocal = address == null || address.equals(LOCAL) ||
-                             address.startsWith(LOCAL_COLON);
-    String host = c.get(MASTER_HOST_NAME);
-    boolean hostIsLocal = host == null || host.equals(LOCAL);
-    return addressIsLocal && hostIsLocal;
+    String mode = c.get(CLUSTER_DISTRIBUTED);
+    return mode == null || mode.equals(CLUSTER_IS_LOCAL);
   }
 
   /**

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/HMaster.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/HMaster.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/HMaster.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/HMaster.java Tue Jun  2 17:52:32
2009
@@ -85,6 +85,7 @@
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.ipc.RemoteException;
+import org.apache.hadoop.net.DNS;
 import org.apache.hadoop.util.StringUtils;
 
 /**
@@ -161,17 +162,12 @@
    * @throws IOException
    */
   public HMaster(HBaseConfiguration conf) throws IOException {
-    // find out our address. If it's set in config, use that, otherwise look it
-    // up in DNS.
-    String addressStr = conf.get(MASTER_ADDRESS);
-    if (addressStr == null) {
-      addressStr = conf.get(MASTER_HOST_NAME);
-      if (addressStr == null) {
-        addressStr = InetAddress.getLocalHost().getCanonicalHostName();
-      }
-      addressStr += ":";
-      addressStr += conf.get("hbase.master.port", Integer.toString(DEFAULT_MASTER_PORT));
-    }
+    // find out our address up in DNS.
+    String addressStr = DNS.getDefaultHost(
+        conf.get("hbase.master.dns.interface","default"),
+        conf.get("hbase.master.dns.nameserver","default"));
+    addressStr += ":" + 
+      conf.get("hbase.master.port", Integer.toString(DEFAULT_MASTER_PORT));
     HServerAddress address = new HServerAddress(addressStr);
     LOG.info("My address is " + address);
 
@@ -531,7 +527,7 @@
           this.connection.getHRegionConnection(address, false);
         HServerInfo info = hri.getHServerInfo();
         LOG.debug("Inspection found server " + info.getName());
-        serverManager.recordNewServer(info);
+        serverManager.recordNewServer(info, true);
         HRegionInfo[] regions = hri.getRegionsAssignment();
         for (HRegionInfo region : regions) {
           if(region.isRootRegion()) {
@@ -1075,13 +1071,7 @@
 
     // Process command-line args. TODO: Better cmd-line processing
     // (but hopefully something not as painful as cli options).
-
-    final String addressArgKey = "--bind=";
     for (String cmd: args) {
-      if (cmd.startsWith(addressArgKey)) {
-        conf.set(MASTER_ADDRESS, cmd.substring(addressArgKey.length()));
-        continue;
-      }
 
       if (cmd.equals("start")) {
         try {

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/ServerManager.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/ServerManager.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/ServerManager.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/master/ServerManager.java Tue Jun
 2 17:52:32 2009
@@ -194,12 +194,23 @@
     recordNewServer(info);
   }
   
+  
   /**
-   * Adds the HSI to the RS list
+   * Adds the HSI to the RS list and creates an empty load
    * @param info The region server informations
    */
   public void recordNewServer(HServerInfo info) {
-    HServerLoad load = new HServerLoad();
+    recordNewServer(info, false);
+  }
+  
+  /**
+   * Adds the HSI to the RS list
+   * @param info The region server informations
+   * @param useInfoLoad True if the load from the info should be used
+   *                    like under a master failover
+   */
+  public void recordNewServer(HServerInfo info, boolean useInfoLoad) {
+    HServerLoad load = useInfoLoad ? info.getLoad() : new HServerLoad();
     String serverName = HServerInfo.getServerName(info);
     info.setLoad(load);
     // We must set this watcher here because it can be set on a fresh start

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/HQuorumPeer.java Tue Jun
 2 17:52:32 2009
@@ -101,6 +101,7 @@
     }
     for (Entry<Object, Object> entry : properties.entrySet()) {
       String value = entry.getValue().toString().trim();
+      String key = entry.getKey().toString().trim();
       StringBuilder newValue = new StringBuilder();
       int varStart = value.indexOf(VARIABLE_START);
       int varEnd = 0;
@@ -123,19 +124,24 @@
           LOG.fatal(msg);
           throw new IOException(msg);
         }
-        // Special case for 'hbase.master.hostname' property being 'local'
-        if (variable.equals(HConstants.MASTER_HOST_NAME) && substituteValue.equals("local"))
{
-          substituteValue = "localhost";
-        }
+        
         newValue.append(substituteValue);
 
         varEnd += VARIABLE_END_LENGTH;
         varStart = value.indexOf(VARIABLE_START, varEnd);
       }
-
+      // Special case for 'hbase.cluster.distributed' property being 'true'
+      if (key.startsWith("server.")) {
+        if(conf.get(CLUSTER_DISTRIBUTED).equals(CLUSTER_IS_DISTRIBUTED) && 
+            value.startsWith("localhost")) {
+           String msg = "The server in zoo.cfg cannot be set to localhost " +
+              "in a fully-distributed setup because it won't be reachable. " +
+              "See \"Getting Started\" for more information.";
+           LOG.fatal(msg);
+           throw new IOException(msg);
+        }
+      }
       newValue.append(value.substring(varEnd));
-
-      String key = entry.getKey().toString().trim();
       properties.setProperty(key, newValue.toString());
     }
     return properties;

Modified: hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java (original)
+++ hadoop/hbase/trunk/src/java/org/apache/hadoop/hbase/zookeeper/ZooKeeperWrapper.java Tue
Jun  2 17:52:32 2009
@@ -152,8 +152,8 @@
     try {
       properties = HQuorumPeer.parseZooKeeperConfig();
     } catch (IOException e) {
-      LOG.error("fail to read properties from " + ZOOKEEPER_CONFIG_NAME);
-      return;
+      LOG.fatal("Fail to read properties from " + ZOOKEEPER_CONFIG_NAME, e);
+      System.exit(-1);
     }
 
     String clientPort = null;
@@ -532,9 +532,9 @@
         zooKeeper.delete(joinPath(this.rsZNode, node), -1);
       }
     } catch (KeeperException e) {
-      LOG.warn("Failed to delete " + rsZNode + " znode in ZooKeeper: " + e);
+      LOG.warn("Failed to delete " + rsZNode + " znodes in ZooKeeper: " + e);
     } catch (InterruptedException e) {
-      LOG.warn("Failed to delete " + rsZNode + " znode in ZooKeeper: " + e);
+      LOG.warn("Failed to delete " + rsZNode + " znodes in ZooKeeper: " + e);
     }
   }
   

Modified: hadoop/hbase/trunk/src/java/overview.html
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/java/overview.html?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/java/overview.html (original)
+++ hadoop/hbase/trunk/src/java/overview.html Tue Jun  2 17:52:32 2009
@@ -79,15 +79,9 @@
 </p>
 
 <h2><a name="distributed">Distributed Operation</a></h2>
-<p>Distributed mode requires an instance of the Hadoop Distributed File System (DFS)
and a ZooKeeper cluster.
+<p>Distributed mode requires an instance of the Hadoop Distributed File System (DFS).
 See the Hadoop <a href="http://lucene.apache.org/hadoop/api/overview-summary.html#overview_description">
 requirements and instructions</a> for how to set up a DFS.
-See the ZooKeeeper <a href="http://hadoop.apache.org/zookeeper/docs/current/zookeeperStarted.html">Getting
Started Guide</a>
-for information about the ZooKeeper distributed coordination service.
-If you do not configure a ZooKeeper cluster, HBase will manage a single instance
-ZooKeeper service for you running on the master node.
-This is intended for development and local testing only.
-It SHOULD NOT be used in a fully-distributed production operation.
 </p>
 
 <h3><a name="pseudo-distrib">Pseudo-Distributed Operation</a></h3>
@@ -122,21 +116,19 @@
 For running a fully-distributed operation on more than one host, the following
 configurations must be made <i>in addition</i> to those described in the
 <a href="#pseudo-distrib">pseudo-distributed operation</a> section above.
+A Zookeeper cluster is also required to ensure higher availability.
 In <code>hbase-site.xml</code>, you must also configure
-<code>hbase.master.hostname</code> to the host on which the HBase master runs
-(<a href="http://wiki.apache.org/lucene-hadoop/Hbase/HbaseArchitecture">read 
-about the HBase master, regionservers, etc</a>).
-For example, adding the below to your <code>hbase-site.xml</code> says the
-master is up on the host example.org:
+<code>hbase.cluster.distributed</code> to 'true'. 
 </p>
 <pre>
 &lt;configuration&gt;
   ...
   &lt;property&gt;
-    &lt;name&gt;hbase.master.hostname&lt;/name&gt;
-    &lt;value&gt;example.org&lt;/value&gt;
-    &lt;description&gt;The host that the HBase master runs at.
-      A value of 'local' runs the master and regionserver in a single process.
+    &lt;name&gt;hbase.cluster.distributed&lt;/name&gt;
+    &lt;value&gt;true&lt;/value&gt;
+    &lt;description&gt;The mode the cluster will be in. Possible values are
+      false: standalone and pseudo-distributed setups with managed Zookeeper
+      true: fully-distributed with unmanaged Zookeeper Quorum (see hbase-env.sh)
     &lt;/description&gt;
   &lt;/property&gt;
   ...
@@ -151,14 +143,35 @@
 in HBase is like the hadoop slaves file at <code>${HADOOP_HOME}/conf/slaves</code>).
 </p>
 <p>
-Furthermore, you should configure a distributed ZooKeeper cluster.
+Furthermore, you have to configure a distributed ZooKeeper cluster.
 The ZooKeeper configuration file is stored at <code>${HBASE_HOME}/conf/zoo.cfg</code>.
 See the ZooKeeper <a href="http://hadoop.apache.org/zookeeper/docs/current/zookeeperStarted.html">
Getting Started Guide</a> for information about the format and options of that file.
 Specifically, look at the <a href="http://hadoop.apache.org/zookeeper/docs/current/zookeeperStarted.html#sc_RunningReplicatedZooKeeper">Running
Replicated ZooKeeper</a> section.
-In <code>${HBASE_HOME}/conf/hbase-env.sh</code>, set <code>HBASE_MANAGES_ZK=false</code>
to tell HBase not to manage its own single instance ZooKeeper service.
+In <code>${HBASE_HOME}/conf/hbase-env.sh</code>, set the following to tell HBase
not to manage its own single instance of ZooKeeper.
+<pre>
+  ...
+# Tell HBase whether it should manage it's own instance of Zookeeper or not.
+export HBASE_MANAGES_ZK=false
+</pre>
 </p>
+<p>
+It's still possible to use HBase in order to start a single Zookeeper instance in fully-distributed
operation.
+The first thing to do is still to change <code>${HBASE_HOME}/conf/zoo.cfg</code>
and set a single node.
+Note that leaving the value "localhost" will make it impossible to start HBase.
+<pre>
+  ...
+server.0=example.org:2888:3888
+</pre>
+Then on the example.org server do the following <i>before</i> running HBase.

+<pre>
+${HBASE_HOME}/bin/hbase-daemon.sh start zookeeper
+</pre>
+Be aware that this option is only recommanded for testing purposes as a failure
+on that node would render HBase <b>unusable</b>.
+</p>
+
 
-<p>Of note, if you have made <i>HDFS client configuration</i> on your hadoop
cluster, hbase will not
+<p>Of note, if you have made <i>HDFS client configuration</i> on your hadoop
cluster, HBase will not
 see this configuration unless you do one of the following:
 <ul>
     <li>Add a pointer to your <code>HADOOP_CONF_DIR</code> to <code>CLASSPATH</code>
in <code>hbase-env.sh</code></li>
@@ -167,7 +180,7 @@
 </ul>
 An example of such an HDFS client configuration is <code>dfs.replication</code>.
 If for example,
 you want to run with a replication factor of 5, hbase will create files with the default
of 3 unless 
-you do the above to make the configuration available to hbase.
+you do the above to make the configuration available to HBase.
 </p>
 
 <h2><a name="runandconfirm">Running and Confirming Your Installation</a></h2>

Modified: hadoop/hbase/trunk/src/test/org/apache/hadoop/hbase/PerformanceEvaluation.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/test/org/apache/hadoop/hbase/PerformanceEvaluation.java?rev=781099&r1=781098&r2=781099&view=diff
==============================================================================
--- hadoop/hbase/trunk/src/test/org/apache/hadoop/hbase/PerformanceEvaluation.java (original)
+++ hadoop/hbase/trunk/src/test/org/apache/hadoop/hbase/PerformanceEvaluation.java Tue Jun
 2 17:52:32 2009
@@ -767,12 +767,6 @@
           errCode = 0;
           break;
         }
-        
-        final String masterArgKey = "--master=";
-        if (cmd.startsWith(masterArgKey)) {
-          this.conf.set(MASTER_ADDRESS, cmd.substring(masterArgKey.length()));
-          continue;
-        }
        
         final String miniClusterArgKey = "--miniCluster";
         if (cmd.startsWith(miniClusterArgKey)) {



Mime
View raw message