Index: src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java =================================================================== --- src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java (revision 1100234) +++ src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestWALReplay.java (working copy) @@ -382,7 +382,7 @@ final Configuration newConf = HBaseConfiguration.create(this.conf); User user = HBaseTestingUtility.getDifferentUser(newConf, ".replay.wal.secondtime"); - user.runAs(new PrivilegedExceptionAction(){ + user.runAs(new PrivilegedExceptionAction() { public Object run() throws Exception { runWALSplit(newConf); FileSystem newFS = FileSystem.get(newConf); @@ -392,10 +392,12 @@ HLog newWal = createWAL(newConf); final AtomicInteger flushcount = new AtomicInteger(0); try { - final HRegion region = new HRegion(basedir, newWal, newFS, newConf, hri, - null) { - protected boolean internalFlushcache(HLog wal, long myseqid) + final HRegion region = + new HRegion(basedir, newWal, newFS, newConf, hri, null) { + protected boolean internalFlushcache( + final HLog wal, final long myseqid, MonitoredTask status) throws IOException { + LOG.info("InternalFlushCache Invoked"); boolean b = super.internalFlushcache(wal, myseqid, Mockito.mock(MonitoredTask.class)); flushcount.incrementAndGet(); @@ -404,7 +406,7 @@ }; long seqid = region.initialize(); // We flushed during init. - assertTrue(flushcount.get() > 0); + assertTrue("Flushcount=" + flushcount.get(), flushcount.get() > 0); assertTrue(seqid > wal.getSequenceNumber()); Get get = new Get(rowName); @@ -494,7 +496,7 @@ this.hbaseRootDir, this.logDir, this.oldLogDir, fs); List splits = logSplitter.splitLog(); // Split should generate only 1 file since there's only 1 region - assertEquals(1, splits.size()); + assertEquals("splits=" + splits, 1, splits.size()); // Make sure the file exists assertTrue(fs.exists(splits.get(0))); LOG.info("Split file=" + splits.get(0));