Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.2 d669a4fb6 -> f4e1c7e0d
PHOENIX-4785 Unable to write to table if index is made active during retry (addendum for test) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/f4e1c7e0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/f4e1c7e0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/f4e1c7e0 Branch: refs/heads/4.x-HBase-1.2 Commit: f4e1c7e0d7b2fd58bc83b71d247c773a698d0d54 Parents: d669a4f Author: Vincent Poon <[email protected]> Authored: Fri Oct 12 15:49:39 2018 -0700 Committer: Vincent Poon <[email protected]> Committed: Tue Oct 16 16:22:00 2018 -0700 ---------------------------------------------------------------------- .../org/apache/phoenix/end2end/index/MutableIndexFailureIT.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/f4e1c7e0/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java ---------------------------------------------------------------------- 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 9bf82fe..06f8f68 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 @@ -433,7 +433,7 @@ public class MutableIndexFailureIT extends BaseTest { private void addRowsInTableDuringRetry(final String tableName) throws SQLException, InterruptedException, ExecutionException { - int threads=10; + int threads=9; boolean wasFailWrite = FailingRegionObserver.FAIL_WRITE; boolean wasToggleFailWriteForRetry = FailingRegionObserver.TOGGLE_FAIL_WRITE_FOR_RETRY; try { @@ -610,6 +610,9 @@ public class MutableIndexFailureIT extends BaseTest { } } } + if (TOGGLE_FAIL_WRITE_FOR_RETRY) { + FAIL_WRITE = !FAIL_WRITE; + } } } if (throwException) {
