You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ai...@apache.org on 2016/12/01 14:34:45 UTC
hive git commit: HIVE-15321: Change to read as long for
HiveConf.ConfVars.METASTORESERVERMAXMESSAGESIZE (Aihua Xu,
reviewed by Yongzhi Chen)
Repository: hive
Updated Branches:
refs/heads/master 54b3abf52 -> 803717bc7
HIVE-15321: Change to read as long for HiveConf.ConfVars.METASTORESERVERMAXMESSAGESIZE (Aihua Xu, reviewed by Yongzhi Chen)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/803717bc
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/803717bc
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/803717bc
Branch: refs/heads/master
Commit: 803717bc7644c7e696451e91dec53ab62d10f5ee
Parents: 54b3abf
Author: Aihua Xu <ai...@apache.org>
Authored: Thu Dec 1 09:34:02 2016 -0500
Committer: Aihua Xu <ai...@apache.org>
Committed: Thu Dec 1 09:34:02 2016 -0500
----------------------------------------------------------------------
common/src/java/org/apache/hadoop/hive/conf/HiveConf.java | 2 +-
.../src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/803717bc/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
----------------------------------------------------------------------
diff --git a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
index 39e3e5e..b809562 100644
--- a/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
+++ b/common/src/java/org/apache/hadoop/hive/conf/HiveConf.java
@@ -666,7 +666,7 @@ public class HiveConf extends Configuration {
"the connection URL, before the next metastore query that accesses the\n" +
"datastore. Once reloaded, this value is reset to false. Used for\n" +
"testing only."),
- METASTORESERVERMAXMESSAGESIZE("hive.metastore.server.max.message.size", 100*1024*1024,
+ METASTORESERVERMAXMESSAGESIZE("hive.metastore.server.max.message.size", 100*1024*1024L,
"Maximum message size in bytes a HMS will accept."),
METASTORESERVERMINTHREADS("hive.metastore.server.min.threads", 200,
"Minimum number of worker threads in the Thrift server's pool."),
http://git-wip-us.apache.org/repos/asf/hive/blob/803717bc/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
index 54fd544..f7b2ed7 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
@@ -7121,7 +7121,7 @@ public class HiveMetaStore extends ThriftHiveMetastore {
// Server will create new threads up to max as necessary. After an idle
// period, it will destroy threads to keep the number of threads in the
// pool to min.
- long maxMessageSize = conf.getIntVar(HiveConf.ConfVars.METASTORESERVERMAXMESSAGESIZE);
+ long maxMessageSize = conf.getLongVar(HiveConf.ConfVars.METASTORESERVERMAXMESSAGESIZE);
int minWorkerThreads = conf.getIntVar(HiveConf.ConfVars.METASTORESERVERMINTHREADS);
int maxWorkerThreads = conf.getIntVar(HiveConf.ConfVars.METASTORESERVERMAXTHREADS);
boolean tcpKeepAlive = conf.getBoolVar(HiveConf.ConfVars.METASTORE_TCP_KEEP_ALIVE);