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/3a0ce7d0 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/3a0ce7d0 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/3a0ce7d0 Branch: refs/heads/calcite Commit: 3a0ce7d0f31bddc1ea802d66dde91bdde0e01504 Parents: eb73271 Author: Thomas D'Silva <twdsi...@gmail.com> Authored: Thu Apr 2 17:50:58 2015 -0700 Committer: Thomas D'Silva <twdsi...@gmail.com> Committed: Thu Apr 2 17:56:37 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/3a0ce7d0/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 dbcd7ac..4d3620f 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 @@ -221,8 +221,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();