[hive] branch master updated: HIVE-22904: Compaction cleaner cannot find COMPACTION_QUEUE table using postgres db

[lpinter]

This is an automated email from the ASF dual-hosted git repository.

lpinter 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 1046517  HIVE-22904: Compaction cleaner cannot find COMPACTION_QUEUE 
table using postgres db
1046517 is described below

commit 10465174aef4c26edf7f7ee647f6e1ceeb4a272d
Author: Laszlo Pinter <lpin...@cloudera.com>
AuthorDate: Tue Feb 25 15:11:41 2020 +0100

    HIVE-22904: Compaction cleaner cannot find COMPACTION_QUEUE table using 
postgres db
---
 .../org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
index 0f94e13..19a95b6 100644
--- 
a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
+++ 
b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/CompactionTxnHandler.java
@@ -76,7 +76,7 @@ class CompactionTxnHandler extends TxnHandler {
         stmt = dbConn.createStatement();
         // Check for completed transactions
         String s = "SELECT DISTINCT \"TC\".\"CTC_DATABASE\", 
\"TC\".\"CTC_TABLE\", \"TC\".\"CTC_PARTITION\" " +
-          "FROM \"COMPLETED_TXN_COMPONENTS\" TC " + (checkInterval > 0 ?
+          "FROM \"COMPLETED_TXN_COMPONENTS\" \"TC\" " + (checkInterval > 0 ?
           "LEFT JOIN ( " +
           "  SELECT \"C1\".* FROM \"COMPLETED_COMPACTIONS\" \"C1\" " +
           "  INNER JOIN ( " +
@@ -382,7 +382,7 @@ class CompactionTxnHandler extends TxnHandler {
           throw new IllegalStateException("No record with CQ_ID=" + info.id + 
" found in COMPACTION_QUEUE");
         }
         close(rs);
-        String s = "delete from COMPACTION_QUEUE where cq_id = ?";
+        String s = "delete from \"COMPACTION_QUEUE\" where \"CQ_ID\" = ?";
         pStmt = dbConn.prepareStatement(s);
         pStmt.setLong(1, info.id);
         LOG.debug("Going to execute update <" + s + ">");