Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18905 addendum fix hanging TestFlushLifeCycleTracker

Browse Source
This commit is contained in:
zhangduo 2017-10-27 10:56:21 +08:00
parent 82b1c320f0
commit 090c10f2a4
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestFlushLifeCycleTracker.java
View File

@ -45,7 +45,6 @@ import org.junit.After;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
@ -53,13 +52,12 @@ import org.junit.experimental.categories.Category;
* Confirm that the function of FlushLifeCycleTracker is OK as we do not use it in our own code. * Confirm that the function of FlushLifeCycleTracker is OK as we do not use it in our own code.
*/ */
@Category({ CoprocessorTests.class, MediumTests.class }) @Category({ CoprocessorTests.class, MediumTests.class })
@Ignore
public class TestFlushLifeCycleTracker { public class TestFlushLifeCycleTracker {
private static final HBaseTestingUtility UTIL = new HBaseTestingUtility(); private static final HBaseTestingUtility UTIL = new HBaseTestingUtility();
private static final TableName NAME = private static final TableName NAME =
TableName.valueOf(TestCompactionLifeCycleTracker.class.getSimpleName()); TableName.valueOf(TestFlushLifeCycleTracker.class.getSimpleName());
private static final byte[] CF = Bytes.toBytes("CF"); private static final byte[] CF = Bytes.toBytes("CF");
@ -116,11 +114,11 @@ public class TestFlushLifeCycleTracker {
CountDownLatch arrive = ARRIVE; CountDownLatch arrive = ARRIVE;
if (arrive != null) { if (arrive != null) {
arrive.countDown(); arrive.countDown();
} try {
try { BLOCK.await();
BLOCK.await(); } catch (InterruptedException e) {
} catch (InterruptedException e) { throw new InterruptedIOException();
throw new InterruptedIOException(); }
} }
} }
} }