This is an automated email from the ASF dual-hosted git repository.
kgyrtkirk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new 4ce96653713 HIVE-25879: MetaStoreDirectSql test query should not query
the whole DBS table (#3348) (Miklos Szurap reviewed by Zoltan Haindrich)
4ce96653713 is described below
commit 4ce96653713325570a83704d2e131e284acdfe65
Author: mszurap <[email protected]>
AuthorDate: Tue Jun 14 15:15:18 2022 +0200
HIVE-25879: MetaStoreDirectSql test query should not query the whole DBS
table (#3348) (Miklos Szurap reviewed by Zoltan Haindrich)
---
.../java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java
index d24128c9618..6be4c3f84a0 100644
---
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java
+++
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java
@@ -316,6 +316,7 @@ class MetaStoreDirectSql {
}
private boolean runTestQuery() {
+ boolean doTrace = LOG.isDebugEnabled();
Transaction tx = pm.currentTransaction();
boolean doCommit = false;
if (!tx.isActive()) {
@@ -323,10 +324,12 @@ class MetaStoreDirectSql {
doCommit = true;
}
// Run a self-test query. If it doesn't work, we will self-disable. What a
PITA...
- String selfTestQuery = "select \"DB_ID\" from " + DBS + "";
+ String selfTestQuery = "select \"DB_ID\" from " + DBS + " WHERE
\"DB_ID\"=1";
try (QueryWrapper query = new
QueryWrapper(pm.newQuery("javax.jdo.query.SQL", selfTestQuery))) {
prepareTxn();
+ long start = doTrace ? System.nanoTime() : 0;
query.execute();
+ MetastoreDirectSqlUtils.timingTrace(doTrace, selfTestQuery, start,
doTrace ? System.nanoTime() : 0);
return true;
} catch (Throwable t) {
doCommit = false;