Repository: ignite Updated Branches: refs/heads/master 51d36e8f6 -> 2a0e35426
Fixed error in TcpDiscoveryMultiThreadedTest.testCustomEventOnJoinCoordinatorStop. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2a0e3542 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2a0e3542 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2a0e3542 Branch: refs/heads/master Commit: 2a0e3542604ec5ebca24587835f4c2e8e4c0a3e3 Parents: 51d36e8 Author: sboikov <[email protected]> Authored: Thu Nov 29 22:27:01 2018 +0300 Committer: sboikov <[email protected]> Committed: Thu Nov 29 22:27:01 2018 +0300 ---------------------------------------------------------------------- .../spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/2a0e3542/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java index 8f3ce0a..b0e3f85 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java @@ -110,6 +110,8 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); + cfg.setConsistentId(igniteInstanceName); + UUID id = nodeId.get(); if (id != null) { @@ -514,11 +516,13 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { IgniteInternalFuture<?> fut1 = GridTestUtils.runAsync(new Callable<Void>() { @Override public Void call() throws Exception { - CacheConfiguration ccfg = new CacheConfiguration(DEFAULT_CACHE_NAME); + String cacheName = DEFAULT_CACHE_NAME + "-tmp"; Ignite ignite = ignite(START_NODES - 1); while (!stop.get()) { + CacheConfiguration ccfg = new CacheConfiguration(cacheName); + ignite.createCache(ccfg); ignite.destroyCache(ccfg.getName());
