[phoenix] branch master updated: PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and MutableIndexSplitReverseScanIT.

[larsh]

This is an automated email from the ASF dual-hosted git repository.

larsh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/master by this push:
     new 0828e92  PHOENIX-5336 Speed up MutableIndexSplitForwardScanIT and 
MutableIndexSplitReverseScanIT.
0828e92 is described below

commit 0828e92c5e2ee99c7ef0ed407ae3c03b95c32958
Author: Lars Hofhansl <la...@apache.org>
AuthorDate: Wed Jun 12 13:46:54 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 14bc465..14028e3 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<RegionInfo> regionsOfUserTable = null;
         for(int i = 0; i <=1; i++) {
-            Threads.sleep(10000);
             if(localIndex) {
                 admin.split(TableName.valueOf(tableName),
                     ByteUtil.concat(Bytes.toBytes(splitKeys[i])));
@@ -147,13 +146,13 @@ public abstract class MutableIndexSplitIT extends 
ParallelStatsDisabledIT {
                     MetaTableAccessor.getTableRegions(admin.getConnection(),
                         TableName.valueOf(localIndex ? tableName : indexName), 
false);
 
-            while (regionsOfUserTable.size() != (i+2)) {
+            while (regionsOfUserTable.size() < (i+2)) {
                 Thread.sleep(100);
                 regionsOfUserTable =
                         
MetaTableAccessor.getTableRegions(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());