From 1bd9c68b7bbbdc0f29be649e1a83d8a5df398b1d Mon Sep 17 00:00:00 2001 From: Deepesh Khandelwal Date: Mon, 21 Sep 2015 09:13:45 -0700 Subject: [PATCH] HIVE-11902: Abort txn cleanup thread throws SyntaxErrorException --- .../src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java index 9ecb82a..8597d9f 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java @@ -1302,6 +1302,9 @@ private void checkQFileTestHack() { private int abortTxns(Connection dbConn, List txnids) throws SQLException { Statement stmt = null; int updateCnt = 0; + if (txnids.isEmpty()) { + return 0; + } try { stmt = dbConn.createStatement(); @@ -1921,7 +1924,7 @@ public void performTimeOuts() { abortTxns(dbConn, batchToAbort); dbConn.commit(); //todo: add TXNS.COMMENT filed and set it to 'aborted by system due to timeout' - LOG.info("Aborted the following transactions due to timeout: " + timedOutTxns.toString()); + LOG.info("Aborted the following transactions due to timeout: " + batchToAbort.toString()); } int numTxnsAborted = (timedOutTxns.size() - 1) * TIMED_OUT_TXN_ABORT_BATCH_SIZE + timedOutTxns.get(timedOutTxns.size() - 1).size(); -- 2.3.8 (Apple Git-58)