IGNITE-7871 Check local join future on error. - Fixes #3793. Signed-off-by: dpavlov <dpav...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0e73fa2c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0e73fa2c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0e73fa2c Branch: refs/heads/ignite-7708 Commit: 0e73fa2c10dcd96ff98279018bdd3f8b36568008 Parents: 74d2545 Author: Pavel Kovalenko <jokse...@gmail.com> Authored: Wed Apr 11 14:12:50 2018 +0300 Committer: dpavlov <dpav...@apache.org> Committed: Wed Apr 11 14:12:50 2018 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/latch/ExchangeLatchManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0e73fa2c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java index c205cb1..404f88f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java @@ -104,7 +104,8 @@ public class ExchangeLatchManager { // First coordinator initialization. ctx.discovery().localJoinFuture().listen(f -> { - this.coordinator = getLatchCoordinator(AffinityTopologyVersion.NONE); + if (f.error() == null) + this.coordinator = getLatchCoordinator(AffinityTopologyVersion.NONE); }); ctx.event().addDiscoveryEventListener((e, cache) -> {