diff --git common/src/java/org/apache/hadoop/hive/conf/HiveConf.java common/src/java/org/apache/hadoop/hive/conf/HiveConf.java index f86d6a7..d653d90 100644 --- common/src/java/org/apache/hadoop/hive/conf/HiveConf.java +++ common/src/java/org/apache/hadoop/hive/conf/HiveConf.java @@ -969,13 +969,6 @@ public class HiveConf extends Configuration { "connecting to a remote metastore."); } - if (null != this.get(ConfVars.METASTOREURIS.varname, null) && - null != this.get(ConfVars.METASTORECONNECTURLKEY.varname, null)) { - l4j.error("Found both " + ConfVars.METASTOREURIS.varname + " and " + - ConfVars.METASTORECONNECTURLKEY + " Recommended to have exactly one of those config key" + - "in configuration"); - } - // if the running class was loaded directly (through eclipse) rather than through a // jar then this would be needed if (hiveJar == null) { diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index 17b986c..4bafbc5 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -194,21 +194,21 @@ public class HiveMetaStoreClient implements IMetaStoreClient { private void open() throws MetaException { for (URI store : metastoreUris) { - LOG.info("Trying to connect to metastore with URI " + store); + LOG.info("Trying to connect to HiveMetaStore with URI " + store); try { openStore(store); } catch (MetaException e) { - LOG.error("Unable to connect to metastore with URI " + store, e); + LOG.error("Unable to connect to HiveMetaStore with URI " + store, e); } if (isConnected) { + LOG.info("Connected to HiveMetaStore with URI " + store); break; } } if (!isConnected) { - throw new MetaException( - "Could not connect to meta store using any of the URIs provided"); + throw new MetaException("Could not connect to HiveMetaStore using any of the provided URIs: " + + Arrays.asList(metastoreUris)); } - LOG.info("Connected to metastore."); } private void openStore(URI store) throws MetaException { diff --git metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java index 1a15500..7af1f4c 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreUtils.java @@ -483,7 +483,7 @@ public class MetaStoreUtils { } ddl.append("}"); - LOG.info("DDL: " + ddl); + LOG.debug("DDL: " + ddl); return ddl.toString(); } diff --git ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java index 7440889..dd76b7b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -196,7 +196,7 @@ public class Hive { * closes the connection to metastore for the calling thread */ private void close() { - LOG.info("Closing current thread's connection to Hive Metastore."); + LOG.debug("Closing current thread's connection to Hive Metastore."); if (metaStoreClient != null) { metaStoreClient.close(); metaStoreClient = null;