diff --git standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 4601e09422..5aba1882a7 100644 --- standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -646,6 +646,10 @@ public void setMetaConf(String key, String value) throws MetaException { setHMSHandler(this); configuration.set(key, value); notifyMetaListeners(key, oldValue, value); + + if (ConfVars.TRY_DIRECT_SQL == confVar) { + HMSHandler.LOG.info("Direct SQL optimization = {}", value); + } } @Override @@ -8865,6 +8869,9 @@ public void processContext(ServerContext serverContext, TTransport tTransport, T HMSHandler.LOG.info("TCP keepalive = " + tcpKeepAlive); HMSHandler.LOG.info("Enable SSL = " + useSSL); + boolean directSqlEnabled = MetastoreConf.getBoolVar(conf, ConfVars.TRY_DIRECT_SQL); + HMSHandler.LOG.info("Direct SQL optimization = {}", directSqlEnabled); + if (startLock != null) { signalOtherThreadsToStart(tServer, startLock, startCondition, startedServing); } diff --git standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java index 4e0e887a99..32d8b66fa0 100644 --- standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java +++ standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java @@ -181,7 +181,7 @@ public MetaStoreDirectSql(PersistenceManager pm, Configuration conf, String sche } else { isCompatibleDatastore = ensureDbInit() && runTestQuery(); if (isCompatibleDatastore) { - LOG.info("Using direct SQL, underlying DB is " + dbType); + LOG.debug("Using direct SQL, underlying DB is " + dbType); } } diff --git standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java index 6645e551c2..a646479724 100644 --- standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -3475,6 +3475,7 @@ public T run(boolean initTable) throws MetaException, NoSuchObjectException { try { directSql.prepareTxn(); this.results = getSqlResult(this); + LOG.debug("Using direct SQL optimization."); } catch (Exception ex) { handleDirectSqlError(ex); } @@ -3484,6 +3485,7 @@ public T run(boolean initTable) throws MetaException, NoSuchObjectException { // 2) DirectSQL threw and was disabled in handleDirectSqlError. if (!doUseDirectSql) { this.results = getJdoResult(this); + LOG.debug("Not using direct SQL optimization."); } return commit(); } catch (NoSuchObjectException ex) {