Repository: ignite Updated Branches: refs/heads/ignite-zk 01cd78940 -> cf4d6c813
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/cf4d6c81 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/cf4d6c81 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/cf4d6c81 Branch: refs/heads/ignite-zk Commit: cf4d6c8132c95cbc8a4e07d6e424550463fa024c Parents: 01cd789 Author: sboikov <sboi...@gridgain.com> Authored: Mon Nov 27 17:18:00 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Nov 27 17:18:00 2017 +0300 ---------------------------------------------------------------------- .../discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/cf4d6c81/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java index 2db8c5f..0264ad3 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java @@ -1085,7 +1085,7 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { /** * @throws Exception If failed. */ - public void testClientReconnect1() throws Exception { + public void testClientReconnectSessionExpire1() throws Exception { startGrid(0); sesTimeout = 2000; @@ -1094,7 +1094,11 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { Ignite client = startGrid(1); + client.cache(DEFAULT_CACHE_NAME).put(1, 1); + reconnectClientNodes(log, Collections.singletonList(client), null); + + assertEquals(1, client.cache(DEFAULT_CACHE_NAME).get(1)); } /**
