private void addPartitionInput(Table t) throws Exception {
    Map<String, String> partSpec = new HashMap<String, String>();
    partSpec.put("version", Integer.toString(nextInput++));
    Partition p = new Partition(t, partSpec, new Path("/dev/null"));
    ReadEntity re = new ReadEntity(p);
    readEntities.add(re);
  }
Same as testHeartbeater, but testing cleanup of replication txns (TxnType.REPL_CREATED)
Note: in TestDbTxnManager metastore.repl.txn.timeout is set to 30s for testing purposes.
ql/src/test/org/apache/hadoop/hive/ql/lockmgr/TestDbTxnManager.java