IGNITE-7871 Check local join future on error. - Fixes apache#3793.

Signed-off-by: dpavlov <dpavlov@apache.org>
gridgain · Apr 11, 2018 · d008738 · d008738
1 parent 9874dbf
commit d008738
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...gnite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java b/...gnite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java
@@ -104,7 +104,8 @@ public ExchangeLatchManager(GridKernalContext ctx) {
 
             // 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) -> {