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

HBASE-14647 Disable TestWALProcedureStoreOnHDFS#testWalRollOnLowReplication

This commit is contained in:
stack 2015-10-19 10:39:09 -07:00
parent ea0cf399b4
commit c1f0442045
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestWALProcedureStoreOnHDFS.java
View File

@ -55,6 +55,7 @@ import org.apache.hadoop.hdfs.server.datanode.DataNode;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
import org.mockito.Mockito; import org.mockito.Mockito;
@ -182,7 +183,7 @@ public class TestWALProcedureStoreOnHDFS {
reCount.get() < thread.length); reCount.get() < thread.length);
} }
@Test(timeout=60000) @Ignore ("Needs work") @Test(timeout=60000)
public void testWalRollOnLowReplication() throws Exception { public void testWalRollOnLowReplication() throws Exception {
store.unregisterListener(stopProcedureListener); store.unregisterListener(stopProcedureListener);
store.registerListener(new ProcedureStore.ProcedureStoreListener() { store.registerListener(new ProcedureStore.ProcedureStoreListener() {
@ -191,6 +192,7 @@ public class TestWALProcedureStoreOnHDFS {
@Override @Override
public void abortProcess() { public void abortProcess() {
LOG.info("Aborted!!!!");
} }
}); });
int dnCount = 0; int dnCount = 0;
@ -203,9 +205,12 @@ public class TestWALProcedureStoreOnHDFS {
String msg = re.getMessage(); String msg = re.getMessage();
// We could get a sync failed here...if the test cluster is crawling such that DN recovery // We could get a sync failed here...if the test cluster is crawling such that DN recovery
// is taking a long time. If we've done enough passes, just finish up the test as a 'pass' // is taking a long time. If we've done enough passes, just finish up the test as a 'pass'
if (msg != null && msg.toLowerCase().contains("sync aborted") && i > 50) { if (msg != null && msg.toLowerCase().contains("sync aborted")) {
LOG.info("Returning early... We ran enough of this test", re); LOG.info("i=" + i, re);
return; if (i > 50) {
LOG.info("Returning early... i=" + i + "...We ran enough of this test", re);
return;
}
} }
throw re; throw re;
} }