diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java index a7fd0ef2fa..74e7f23153 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/repl/ReplDumpTask.java @@ -933,12 +933,14 @@ String getValidTxnListForReplDump(Hive hiveDb, long waitUntilTime) throws HiveEx ValidTxnList validTxnList = getTxnMgr().getValidTxns(); while (System.currentTimeMillis() < waitUntilTime) { // If there are no txns which are open for the given ValidTxnList snapshot, then just return it. - if (getOpenTxns(validTxnList).isEmpty()) { + List openTxns = getOpenTxns(validTxnList); + if (openTxns.isEmpty()) { return validTxnList.toString(); } // Wait for 1 minute and check again. try { + LOG.debug("REPL dump waiting for open txns {} to complete, sleeping for 1 minute",openTxns); Thread.sleep(SLEEP_TIME); } catch (InterruptedException e) { LOG.info("REPL DUMP thread sleep interrupted", e);