HBASE-18905 addendum fix hanging TestFlushLifeCycleTracker
This commit is contained in:
parent
fc581270a8
commit
bdcdb5cf9a
|
@ -57,7 +57,7 @@ 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");
|
||||||
|
|
||||||
|
@ -114,7 +114,6 @@ 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) {
|
||||||
|
@ -122,6 +121,7 @@ public class TestFlushLifeCycleTracker {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private static final class Tracker implements FlushLifeCycleTracker {
|
private static final class Tracker implements FlushLifeCycleTracker {
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue