diff --git a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java index c03b252e15..b62220c68b 100644 --- a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java +++ b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/parse/TestReplicationScenariosAcidTables.java @@ -305,7 +305,7 @@ public void testAcidTablesBootstrapWithOpenTxnsDiffDb() throws Throwable { // Bootstrap dump with open txn timeout as 1s. List withConfigs = Arrays.asList( - "'" + HiveConf.ConfVars.REPL_BOOTSTRAP_DUMP_OPEN_TXN_TIMEOUT + "'='1s'"); + "'" + HiveConf.ConfVars.REPL_BOOTSTRAP_DUMP_OPEN_TXN_TIMEOUT + "'='600s'"); WarehouseInstance.Tuple bootstrapDump = primary .run("use " + primaryDbName) .dump(primaryDbName, withConfigs); 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 c897bb4b00..76a2f4fe38 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 @@ -1089,7 +1089,7 @@ String getValidTxnListForReplDump(Hive hiveDb, long waitUntilTime) throws HiveEx ValidTxnList validTxnList = getTxnMgr().getValidTxns(excludedTxns); 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()) { + if (getOpenTxns(validTxnList, work.dbNameOrPattern).isEmpty()) { return validTxnList.toString(); }