You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by td...@apache.org on 2015/04/03 02:55:52 UTC
phoenix git commit: PHOENIX-1803 Fix flapping
PhoenixServerRpcIT.testMetadataQos
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 <tw...@gmail.com>
Authored: Thu Apr 2 17:50:58 2015 -0700
Committer: Thomas D'Silva <tw...@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();