[phoenix] branch master updated: PHOENIX-4993 (addendum) Fix test timeout issue

[vi...@apache.org]

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

vincentpoon 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 bc88c69  PHOENIX-4993 (addendum) Fix test timeout issue
bc88c69 is described below

commit bc88c69426086a546ebf654fde0bc5c925a904f0
Author: Kiran Kumar Maturi <ma...@gmail.com>
AuthorDate: Fri Feb 1 14:05:03 2019 +0530

    PHOENIX-4993 (addendum) Fix test timeout issue
---
 .../apache/phoenix/util/CoprocessorHConnectionTableFactoryTest.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/phoenix-core/src/test/java/org/apache/phoenix/util/CoprocessorHConnectionTableFactoryTest.java b/phoenix-core/src/test/java/org/apache/phoenix/util/CoprocessorHConnectionTableFactoryTest.java
index 3997fca..bf25682 100644
--- a/phoenix-core/src/test/java/org/apache/phoenix/util/CoprocessorHConnectionTableFactoryTest.java
+++ b/phoenix-core/src/test/java/org/apache/phoenix/util/CoprocessorHConnectionTableFactoryTest.java
@@ -98,10 +98,12 @@ public class CoprocessorHConnectionTableFactoryTest extends BaseUniqueNamesOwnCl
     conn.createStatement().execute("CREATE INDEX " + index1Name + " ON " + tableName + "(v1)");
     List<HRegionInfo> regions = admin.getTableRegions(TableName.valueOf(tableName));
     final HRegionInfo regionInfo = regions.get(0);
+
     writeToTable(tableName, conn, noOfOrgs);
     int beforeRegionCloseCount = getActiveConnections(regionServer, conf);
+    int regionsCount = admin.getOnlineRegions(regionServer.getServerName()).size();
     admin.unassign(regionInfo.getEncodedNameAsBytes(), true);
-    getUtility().waitUntilAllRegionsAssigned(TableName.valueOf(tableName));
+    while(!(admin.getOnlineRegions(regionServer.getServerName()).size() < regionsCount));
     int afterRegionCloseCount = getActiveConnections(regionServer, conf);
     assertTrue("Cached connections not closed when region closes: ",
     afterRegionCloseCount == beforeRegionCloseCount && afterRegionCloseCount > 0);