accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
Subject git commit: ACCUMULO-1523 applying Bill Havanki's patch
Date Thu, 19 Sep 2013 18:07:52 GMT
Updated Branches:
  refs/heads/master c16539486 -> b4ce6f88e

ACCUMULO-1523 applying Bill Havanki's patch


Branch: refs/heads/master
Commit: b4ce6f88eb5db3c9a58e9a2d298447cdd2c44287
Parents: c165394
Author: Eric Newton <>
Authored: Thu Sep 19 14:08:04 2013 -0400
Committer: Eric Newton <>
Committed: Thu Sep 19 14:08:04 2013 -0400

 core/src/main/java/org/apache/accumulo/core/conf/    | 3 ++-
 .../org/apache/accumulo/server/tabletserver/     | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/core/src/main/java/org/apache/accumulo/core/conf/ b/core/src/main/java/org/apache/accumulo/core/conf/
index e58e771..b6fbdd2 100644
--- a/core/src/main/java/org/apache/accumulo/core/conf/
+++ b/core/src/main/java/org/apache/accumulo/core/conf/
@@ -109,7 +109,7 @@ public enum Property {
   GENERAL_KERBEROS_KEYTAB("general.kerberos.keytab", "", PropertyType.PATH, "Path to the
kerberos keytab to use. Leave blank if not using kerberoized hdfs"),
   GENERAL_KERBEROS_PRINCIPAL("general.kerberos.principal", "", PropertyType.STRING, "Name
of the kerberos principal to use. _HOST will automatically be "
       + "replaced by the machines hostname in the hostname portion of the principal. Leave
blank if not using kerberoized hdfs"),
-  GENERAL_MAX_MESSAGE_SIZE("tserver.server.message.size.max", "1G", PropertyType.MEMORY,
"The maximum size of a message that can be sent to a tablet server."),
+  GENERAL_MAX_MESSAGE_SIZE("general.server.message.size.max", "1G", PropertyType.MEMORY,
"The maximum size of a message that can be sent to a server."),
   GENERAL_VOLUME_CHOOSER("general.volume.chooser", "org.apache.accumulo.server.fs.RandomVolumeChooser",
PropertyType.CLASSNAME, "The class that will be used to select which volume will be used to
create new files."),
   // properties that are specific to master server behavior
@@ -200,6 +200,7 @@ public enum Property {
   TSERV_BULK_TIMEOUT("tserver.bulk.timeout", "5m", PropertyType.TIMEDURATION, "The time to
wait for a tablet server to process a bulk import request."),
   TSERV_MINTHREADS("tserver.server.threads.minimum", "20", PropertyType.COUNT, "The minimum
number of threads to use to handle incoming requests."),
   TSERV_THREADCHECK("tserver.server.threadcheck.time", "1s", PropertyType.TIMEDURATION, "The
time between adjustments of the server thread pool."),
+  TSERV_MAX_MESSAGE_SIZE("tserver.server.message.size.max", "1G", PropertyType.MEMORY, "The
maximum size of a message that can be sent to a tablet server."),
   TSERV_HOLD_TIME_SUICIDE("tserver.hold.time.max", "5m", PropertyType.TIMEDURATION,
       "The maximum time for a tablet server to be in the \"memory full\" state.  If the tablet
server cannot write out memory"
           + " in this much time, it will assume there is some failure local to its node,
and quit.  A value of zero is equivalent to forever."),
diff --git a/server/src/main/java/org/apache/accumulo/server/tabletserver/
index 7ee0a45..8959d4f 100644
--- a/server/src/main/java/org/apache/accumulo/server/tabletserver/
+++ b/server/src/main/java/org/apache/accumulo/server/tabletserver/
@@ -2936,8 +2936,9 @@ public class TabletServer extends AbstractMetricsImpl implements org.apache.accu
   private InetSocketAddress startServer(AccumuloConfiguration conf, String address, Property
portHint, TProcessor processor, String threadName) throws UnknownHostException {
+    Property maxMessageSizeProperty = (conf.get(Property.TSERV_MAX_MESSAGE_SIZE) != null
     ServerAddress sp = TServerUtils.startServer(conf, address, portHint, processor, this.getClass().getSimpleName(),
threadName, Property.TSERV_PORTSEARCH,
+        Property.TSERV_MINTHREADS, Property.TSERV_THREADCHECK, maxMessageSizeProperty);
     this.server = sp.server;
     return sp.address;

View raw message