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 0f94e13148..19a95b64db 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 @@ public CompactionTxnHandler() { 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 @@ public void markCleaned(CompactionInfo info) throws MetaException { 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 + ">");