HBASE-4252 TestLogRolling's low-probability failure (Jieshan Bean)
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1162426 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
a1ede0c560
commit
82802e8788
|
@ -219,6 +219,7 @@ Release 0.91.0 - Unreleased
|
||||||
the encoded name (ramkrishna.s.vasudevan)
|
the encoded name (ramkrishna.s.vasudevan)
|
||||||
HBASE-3229 HBASE-3229 Table creation, though using "async" call to master,
|
HBASE-3229 HBASE-3229 Table creation, though using "async" call to master,
|
||||||
can actually run for a while and cause RPC timeout (Ming Ma)
|
can actually run for a while and cause RPC timeout (Ming Ma)
|
||||||
|
HBASE-4252 TestLogRolling's low-probability failure (Jieshan Bean)
|
||||||
|
|
||||||
IMPROVEMENTS
|
IMPROVEMENTS
|
||||||
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)
|
HBASE-3290 Max Compaction Size (Nicolas Spiegelberg via Stack)
|
||||||
|
|
|
@ -19,7 +19,10 @@
|
||||||
*/
|
*/
|
||||||
package org.apache.hadoop.hbase.regionserver.wal;
|
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.EOFException;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
@ -29,7 +32,6 @@ import java.lang.reflect.Method;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
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.MiniDFSCluster;
|
||||||
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
|
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
|
||||||
import org.apache.hadoop.hdfs.server.datanode.DataNode;
|
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.hadoop.hdfs.server.namenode.LeaseManager;
|
||||||
import org.apache.log4j.Level;
|
import org.apache.log4j.Level;
|
||||||
import org.junit.After;
|
import org.junit.After;
|
||||||
|
@ -379,12 +380,12 @@ public class TestLogRolling {
|
||||||
dfsCluster.waitActive();
|
dfsCluster.waitActive();
|
||||||
// Force roll writer. The new log file will have the default replications,
|
// Force roll writer. The new log file will have the default replications,
|
||||||
// and the LowReplication Roller will be enabled.
|
// and the LowReplication Roller will be enabled.
|
||||||
log.rollWriter();
|
log.rollWriter(true);
|
||||||
batchWriteAndWait(table, 13, true, 10000);
|
batchWriteAndWait(table, 13, true, 10000);
|
||||||
assertTrue("LowReplication Roller should've been enabled",
|
|
||||||
log.isLowReplicationRollEnabled());
|
|
||||||
assertTrue("New log file should have the default replication",
|
assertTrue("New log file should have the default replication",
|
||||||
log.getLogReplication() == fs.getDefaultReplication());
|
log.getLogReplication() == fs.getDefaultReplication());
|
||||||
|
assertTrue("LowReplication Roller should've been enabled",
|
||||||
|
log.isLowReplicationRollEnabled());
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in New Issue