phoenix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tdsi...@apache.org
Subject phoenix git commit: PHOENIX-1803 Fix flapping PhoenixServerRpcIT.testMetadataQos
Date Fri, 03 Apr 2015 00:55:52 GMT
Repository: phoenix
Updated Branches:
  refs/heads/4.3 b4448693b -> a57f137a1


PHOENIX-1803 Fix flapping PhoenixServerRpcIT.testMetadataQos


Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/a57f137a
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/a57f137a
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/a57f137a

Branch: refs/heads/4.3
Commit: a57f137a1658452601715402ed1c51b733036fbc
Parents: b444869
Author: Thomas D'Silva <twdsilva@gmail.com>
Authored: Thu Apr 2 17:50:58 2015 -0700
Committer: Thomas D'Silva <twdsilva@gmail.com>
Committed: Thu Apr 2 17:50:58 2015 -0700

----------------------------------------------------------------------
 .../src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/a57f137a/phoenix-core/src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java b/phoenix-core/src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java
index 2a7898a..ef7fed4 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/rpc/PhoenixServerRpcIT.java
@@ -220,8 +220,8 @@ public class PhoenixServerRpcIT extends BaseOwnClusterHBaseManagedTimeIT
{
                     "CREATE TABLE " + DATA_TABLE_FULL_NAME + " (k VARCHAR NOT NULL PRIMARY
KEY, v VARCHAR)");
             // query the table from another connection, so that SYSTEM.STATS will be used

             conn.createStatement().execute("SELECT * FROM "+DATA_TABLE_FULL_NAME);
-            // verify that that metadata queue is used once 
-            Mockito.verify(TestPhoenixIndexRpcSchedulerFactory.getMetadataRpcExecutor()).dispatch(Mockito.any(CallRunner.class));
+            // verify that that metadata queue is at least once 
+            Mockito.verify(TestPhoenixIndexRpcSchedulerFactory.getMetadataRpcExecutor(),
Mockito.atLeastOnce()).dispatch(Mockito.any(CallRunner.class));
         }
         finally {
             conn.close();


Mime
View raw message