zk
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7f05c09d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7f05c09d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7f05c09d Branch: refs/heads/ignite-zk-alpha Commit: 7f05c09d3b598db04f69cacc8f9415e97cc1b36c Parents: b33751a8 Author: sboikov <sboi...@gridgain.com> Authored: Fri Dec 8 12:53:40 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Dec 8 13:35:21 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java | 2 ++ .../java/org/apache/ignite/internal/GridJobStealingSelfTest.java | 2 ++ .../cache/index/DynamicIndexAbstractBasicSelfTest.java | 4 +++- 3 files changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7f05c09d/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java index cd6b2c0..a8be541 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobMasterLeaveAwareSelfTest.java @@ -259,6 +259,8 @@ public class GridJobMasterLeaveAwareSelfTest extends GridCommonAbstractTest { // Now we stop master grid. stopGrid(lastGridIdx, true); + waitForTopology(GRID_CNT - 1); + // Release communication SPI wait latches. As master node is stopped, job worker will receive and exception. for (int i = 0; i < lastGridIdx; i++) ((CommunicationSpi)grid(i).configuration().getCommunicationSpi()).releaseWaitLatch(); http://git-wip-us.apache.org/repos/asf/ignite/blob/7f05c09d/modules/core/src/test/java/org/apache/ignite/internal/GridJobStealingSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridJobStealingSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridJobStealingSelfTest.java index f3a19aa..6824d51 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridJobStealingSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridJobStealingSelfTest.java @@ -187,6 +187,8 @@ public class GridJobStealingSelfTest extends GridCommonAbstractTest { public void testProjectionPredicateInternalStealing() throws Exception { final Ignite ignite3 = startGrid(3); + waitForTopology(3); + final UUID node1 = ignite1.cluster().localNode().id(); final UUID node3 = ignite3.cluster().localNode().id(); http://git-wip-us.apache.org/repos/asf/ignite/blob/7f05c09d/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicIndexAbstractBasicSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicIndexAbstractBasicSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicIndexAbstractBasicSelfTest.java index db874c2..37dc5c0 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicIndexAbstractBasicSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicIndexAbstractBasicSelfTest.java @@ -92,9 +92,11 @@ public abstract class DynamicIndexAbstractBasicSelfTest extends DynamicIndexAbst * @param near Near flag. */ private void initialize(CacheMode mode, CacheAtomicityMode atomicityMode, boolean near) - throws IgniteCheckedException { + throws Exception { createSqlCache(node(), cacheConfiguration(mode, atomicityMode, near)); + awaitPartitionMapExchange(); + grid(IDX_CLI_NEAR_ONLY).getOrCreateNearCache(CACHE_NAME, new NearCacheConfiguration<>()); assertNoIndex(CACHE_NAME, TBL_NAME, IDX_NAME_1);
