You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/01/09 14:16:58 UTC
ignite git commit: IgniteCacheContinuousQueryNoUnsubscribeTest: fixed
test to wait for stable topology.
Repository: ignite
Updated Branches:
refs/heads/ignite-3477 31b132dd6 -> 56162b39a
IgniteCacheContinuousQueryNoUnsubscribeTest: fixed test to wait for stable topology.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/56162b39
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/56162b39
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/56162b39
Branch: refs/heads/ignite-3477
Commit: 56162b39a9a86751ea0b791505db14f69348163b
Parents: 31b132d
Author: sboikov <sb...@gridgain.com>
Authored: Mon Jan 9 17:17:04 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Mon Jan 9 17:17:04 2017 +0300
----------------------------------------------------------------------
.../continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/56162b39/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java
index d7beb02..ed53254 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/IgniteCacheContinuousQueryNoUnsubscribeTest.java
@@ -121,6 +121,8 @@ public class IgniteCacheContinuousQueryNoUnsubscribeTest extends GridCommonAbstr
this.client = false;
try (Ignite newSrv = startGrid(3)) {
+ awaitPartitionMapExchange();
+
Integer key = primaryKey(newSrv.cache(null));
newSrv.cache(null).put(key, 1);