diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java index 6e74214..b5848a2 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/TestIOFencing.java @@ -178,6 +178,17 @@ public class TestIOFencing { } @Override + protected void completeCompaction(final Collection compactedFiles, + boolean removeFiles) throws IOException { + try { + r.compactionsWaiting.countDown(); + r.compactionsBlocked.await(); + } catch (InterruptedException ex) { + throw new IOException(ex); + } + super.completeCompaction(compactedFiles, removeFiles); + } + @Override protected void completeCompaction(Collection compactedFiles) throws IOException { try { r.compactionsWaiting.countDown();