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 <[email protected]> Authored: Mon Jan 9 17:17:04 2017 +0300 Committer: sboikov <[email protected]> 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);
