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..b4a65ea83d 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 @@ -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 + ">");