From 8940be05978950d18916d7d67d65c1fa915bd802 Mon Sep 17 00:00:00 2001
From: stack <stack@apache.org>
Date: Mon, 19 Oct 2015 10:39:09 -0700
Subject: [PATCH] HBASE-14647 Disable
 TestWALProcedureStoreOnHDFS#testWalRollOnLowReplication

---
 .../procedure/TestWALProcedureStoreOnHDFS.java      | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestWALProcedureStoreOnHDFS.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestWALProcedureStoreOnHDFS.java
index 1d7dc8391c3..67c4d2003eb 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestWALProcedureStoreOnHDFS.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/procedure/TestWALProcedureStoreOnHDFS.java
@@ -54,6 +54,7 @@ import org.apache.hadoop.hdfs.server.datanode.DataNode;
 
 import org.junit.After;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.mockito.Mockito;
@@ -181,7 +182,7 @@ public class TestWALProcedureStoreOnHDFS {
                                    reCount.get() < thread.length);
   }
 
-  @Test(timeout=60000)
+  @Ignore ("Needs work") @Test(timeout=60000)
   public void testWalRollOnLowReplication() throws Exception {
     store.unregisterListener(stopProcedureListener);
     store.registerListener(new ProcedureStore.ProcedureStoreListener() {
@@ -190,6 +191,7 @@ public class TestWALProcedureStoreOnHDFS {
 
       @Override
       public void abortProcess() {
+        LOG.info("Aborted!!!!");
       }
     });
     int dnCount = 0;
@@ -202,9 +204,12 @@ public class TestWALProcedureStoreOnHDFS {
         String msg = re.getMessage();
         // 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'
-        if (msg != null && msg.toLowerCase().contains("sync aborted") && i > 50) {
-          LOG.info("Returning early... We ran enough of this test", re);
-          return;
+        if (msg != null && msg.toLowerCase().contains("sync aborted")) {
+          LOG.info("i=" + i, re);
+          if (i > 50) {
+            LOG.info("Returning early... i=" + i + "...We ran enough of this test", re);
+            return;
+          }
         }
         throw re;
       }