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/12 20:41:35 UTC
[phoenix] branch 4.x-HBase-1.5 updated: 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 84a2a07 PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT.
84a2a07 is described below
commit 84a2a0788a65137f873a6127f3e85468849053f6
Author: Lars Hofhansl <la...@apache.org>
AuthorDate: Wed Jun 12 13:41:57 2019 -0700
PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT.
---
.../java/org/apache/phoenix/end2end/index/MutableIndexSplitIT.java | 5 ++---
1 file changed, 2 insertions(+), 3 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 c341823..dd375d2 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,7 +135,6 @@ 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])));
@@ -148,14 +147,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);
}
- assertEquals(i+2, regionsOfUserTable.size());
+ assertTrue(regionsOfUserTable.size() >= (i+2));
}
for (int j = 5; j < 26; j++) {
assertTrue(rs.next());