You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2018/07/01 00:30:09 UTC
hive git commit: HIVE-20028: Metastore client cache config is used
incorrectly (Prasanth Jayachandran reviewed by Sergey Shelukhin)
Repository: hive
Updated Branches:
refs/heads/master 6acd74c9e -> 80c3bb58e
HIVE-20028: Metastore client cache config is used incorrectly (Prasanth Jayachandran reviewed by Sergey Shelukhin)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/80c3bb58
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/80c3bb58
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/80c3bb58
Branch: refs/heads/master
Commit: 80c3bb58e24f13f82ca698486645c6c72364d75d
Parents: 6acd74c
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Sat Jun 30 17:17:05 2018 -0700
Committer: Prasanth Jayachandran <pr...@apache.org>
Committed: Sat Jun 30 17:17:05 2018 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java | 2 +-
.../java/org/apache/hive/streaming/HiveStreamingConnection.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/80c3bb58/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java
index 75a7201..3bb654d 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreUtils.java
@@ -225,7 +225,7 @@ public class HiveMetaStoreUtils {
public static IMetaStoreClient getHiveMetastoreClient(HiveConf hiveConf)
throws MetaException, IOException {
- if (HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.METASTORE_CLIENT_CACHE_ENABLED)){
+ if (!HiveConf.getBoolVar(hiveConf, HiveConf.ConfVars.METASTORE_CLIENT_CACHE_ENABLED)){
// If cache is disabled, don't use it.
return HiveClientCache.getNonCachedHiveMetastoreClient(hiveConf);
}
http://git-wip-us.apache.org/repos/asf/hive/blob/80c3bb58/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
----------------------------------------------------------------------
diff --git a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
index d258d0e..7adbadd 100644
--- a/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
+++ b/streaming/src/java/org/apache/hive/streaming/HiveStreamingConnection.java
@@ -1037,7 +1037,7 @@ public class HiveStreamingConnection implements StreamingConnection {
if (LOG.isDebugEnabled()) {
LOG.debug("Overriding HiveConf setting : " + var + " = " + value);
}
- conf.setBoolVar(var, true);
+ conf.setBoolVar(var, value);
}
private static void setHiveConf(HiveConf conf, String var) {