diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java index 13a514f3304..80eca6a4c9a 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java @@ -103,7 +103,6 @@ public class MutableIndexFailureIT extends BaseTest { private static final Logger LOGGER = LoggerFactory.getLogger(MutableIndexFailureIT.class); - public static volatile boolean FAIL_WRITE = false; public static volatile String fullTableName; private String tableName; @@ -415,7 +414,7 @@ public void testIndexWriteFailure() throws Exception { } } finally { - FAIL_WRITE = false; + FailingRegionObserver.FAIL_WRITE = false; } } @@ -611,7 +610,7 @@ private void updateTableAgain(Connection conn, boolean commitShouldFail) throws } public static class FailingRegionObserver extends SimpleRegionObserver { - public static boolean TOGGLE_FAIL_WRITE_FOR_RETRY = false; + public static volatile boolean TOGGLE_FAIL_WRITE_FOR_RETRY = false; public static volatile boolean FAIL_WRITE = false; public static volatile boolean FAIL_NEXT_WRITE = false; public static final String FAIL_INDEX_NAME = "FAIL_IDX";