You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by la...@apache.org on 2019/06/14 01:18:47 UTC
[phoenix] branch 4.x-HBase-1.5 updated: Revert "PHOENIX-5336 Speed
up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT."
This is an automated email from the ASF dual-hosted git repository.
larsh pushed a commit to branch 4.x-HBase-1.5
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.5 by this push:
new 0f4e3d1 Revert "PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT."
0f4e3d1 is described below
commit 0f4e3d1a9822a9300b171bc7be4928a1d437fd1e
Author: Lars Hofhansl <la...@apache.org>
AuthorDate: Thu Jun 13 18:19:04 2019 -0700
Revert "PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT."
This reverts commit 84a2a0788a65137f873a6127f3e85468849053f6.
---
.../java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java
index dd375d2..c341823 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java
@@ -135,6 +135,7 @@ public abstract class MutableIndexSplitIT extends ParallelStatsDisabledIT {
splitInts[1] = 4;
List<HRegionInfo> regionsOfUserTable = null;
for(int i = 0; i <=1; i++) {
+ Threads.sleep(10000);
if(localIndex) {
admin.split(Bytes.toBytes(tableName),
ByteUtil.concat(Bytes.toBytes(splitKeys[i])));
@@ -147,14 +148,14 @@ public abstract class MutableIndexSplitIT extends ParallelStatsDisabledIT {
admin.getConnection(), TableName.valueOf(localIndex?tableName:indexName),
false);
- while (regionsOfUserTable.size() < (i+2)) {
+ while (regionsOfUserTable.size() != (i+2)) {
Thread.sleep(100);
regionsOfUserTable =
MetaTableAccessor.getTableRegions(getUtility().getZooKeeperWatcher(),
admin.getConnection(),
TableName.valueOf(localIndex?tableName:indexName), false);
}
- assertTrue(regionsOfUserTable.size() >= (i+2));
+ assertEquals(i+2, regionsOfUserTable.size());
}
for (int j = 5; j < 26; j++) {
assertTrue(rs.next());