Repository: hbase Updated Branches: refs/heads/master a6314e257 -> c615f2232
HBASE-11619 Remove unused test class from TestHLogSplit (Mikhail Antonov) Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c615f223 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c615f223 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c615f223 Branch: refs/heads/master Commit: c615f223291a1406a7df1ae2a711b4d06e1d61c7 Parents: a6314e2 Author: stack <[email protected]> Authored: Thu Sep 11 10:30:29 2014 -0700 Committer: stack <[email protected]> Committed: Thu Sep 11 10:30:29 2014 -0700 ---------------------------------------------------------------------- .../hbase/regionserver/wal/TestHLogSplit.java | 47 -------------------- 1 file changed, 47 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/c615f223/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java index 3ad7fd4..1fc6b22 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java @@ -34,7 +34,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.NavigableSet; -import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; @@ -1070,52 +1069,6 @@ public class TestHLogSplit { assertEquals(regions.size(), outputCounts.size()); } - /** - * This thread will keep adding new log files - * It simulates a region server that was considered dead but woke up and wrote - * some more to a new hlog - */ - class ZombieNewLogWriterRegionServer extends Thread { - AtomicBoolean stop; - CountDownLatch latch; - public ZombieNewLogWriterRegionServer(CountDownLatch latch, AtomicBoolean stop) { - super("ZombieNewLogWriterRegionServer"); - this.latch = latch; - this.stop = stop; - } - - @Override - public void run() { - if (stop.get()) { - return; - } - Path tableDir = FSUtils.getTableDir(HBASEDIR, TABLE_NAME); - Path regionDir = new Path(tableDir, REGIONS.get(0)); - Path recoveredEdits = new Path(regionDir, HConstants.RECOVERED_EDITS_DIR); - String region = "juliet"; - Path julietLog = new Path(HLOGDIR, HLOG_FILE_PREFIX + ".juliet"); - try { - - while (!fs.exists(recoveredEdits) && !stop.get()) { - LOG.info("Juliet: split not started, sleeping a bit..."); - Threads.sleep(10); - } - - fs.mkdirs(new Path(tableDir, region)); - HLog.Writer writer = HLogFactory.createWALWriter(fs, - julietLog, conf); - appendEntry(writer, TableName.valueOf("juliet"), ("juliet").getBytes(), - ("r").getBytes(), FAMILY, QUALIFIER, VALUE, 0); - writer.close(); - LOG.info("Juliet file creator: created file " + julietLog); - latch.countDown(); - } catch (IOException e1) { - LOG.error("Failed to create file " + julietLog, e1); - assertTrue("Failed to create file " + julietLog, false); - } - } - } - @Test (timeout=300000) public void testSplitLogFileWithOneRegion() throws IOException { LOG.info("testSplitLogFileWithOneRegion");
