Author: tedyu
Date: Sat Aug 27 19:23:32 2011
New Revision: 1162426
URL: http://svn.apache.org/viewvc?rev=1162426&view=rev
Log:
HBASE-4252 TestLogRolling's low-probability failure (Jieshan Bean)
Modified:
hbase/trunk/CHANGES.txt
hbase/trunk/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
Modified: hbase/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hbase/trunk/CHANGES.txt?rev=1162426&r1=1162425&r2=1162426&view=diff
==============================================================================
--- hbase/trunk/CHANGES.txt (original)
+++ hbase/trunk/CHANGES.txt Sat Aug 27 19:23:32 2011
@@ -219,6 +219,7 @@ Release 0.91.0 - Unreleased
the encoded name (ramkrishna.s.vasudevan)
HBASE-3229 HBASE-3229 Table creation, though using "async" call to master,
can actually run for a while and cause RPC timeout (Ming Ma)
+ HBASE-4252 TestLogRolling's low-probability failure (Jieshan Bean)
IMPROVEMENTS
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)
Modified:
hbase/trunk/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
URL:
http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java?rev=1162426&r1=1162425&r2=1162426&view=diff
==============================================================================
---
hbase/trunk/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
(original)
+++
hbase/trunk/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestLogRolling.java
Sat Aug 27 19:23:32 2011
@@ -19,7 +19,10 @@
*/
package org.apache.hadoop.hbase.regionserver.wal;
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
import java.io.EOFException;
import java.io.IOException;
@@ -29,7 +32,6 @@ import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
-import java.util.Map;
import java.util.Set;
import org.apache.commons.logging.Log;
@@ -58,7 +60,6 @@ import org.apache.hadoop.hdfs.DFSClient;
import org.apache.hadoop.hdfs.MiniDFSCluster;
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
import org.apache.hadoop.hdfs.server.datanode.DataNode;
-import org.apache.hadoop.hdfs.server.namenode.FSNamesystem;
import org.apache.hadoop.hdfs.server.namenode.LeaseManager;
import org.apache.log4j.Level;
import org.junit.After;
@@ -379,12 +380,12 @@ public class TestLogRolling {
dfsCluster.waitActive();
// Force roll writer. The new log file will have the default replications,
// and the LowReplication Roller will be enabled.
- log.rollWriter();
+ log.rollWriter(true);
batchWriteAndWait(table, 13, true, 10000);
- assertTrue("LowReplication Roller should've been enabled",
- log.isLowReplicationRollEnabled());
assertTrue("New log file should have the default replication",
log.getLogReplication() == fs.getDefaultReplication());
+ assertTrue("LowReplication Roller should've been enabled",
+ log.isLowReplicationRollEnabled());
}
/**