You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by pb...@apache.org on 2018/10/17 19:25:02 UTC
[31/32] phoenix git commit: PHOENIX-4785 Unable to write to table if
index is made active during retry (addendum for test)
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/e38a3cc6
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e38a3cc6
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e38a3cc6
Branch: refs/heads/4.14-cdh5.11
Commit: e38a3cc6d978616b7f6d8e56578601bef465ca2f
Parents: 893c6e7
Author: Vincent Poon <vi...@apache.org>
Authored: Fri Oct 12 23:49:39 2018 +0100
Committer: Pedro Boado <pb...@apache.org>
Committed: Wed Oct 17 20:23:39 2018 +0100
----------------------------------------------------------------------
.../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/e38a3cc6/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 aac20ac..46a512f 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
@@ -423,7 +423,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 {
@@ -601,6 +601,9 @@ public class MutableIndexFailureIT extends BaseTest {
}
}
}
+ if (TOGGLE_FAIL_WRITE_FOR_RETRY) {
+ FAIL_WRITE = !FAIL_WRITE;
+ }
}
}
if (throwException) {