Check local join future on error. - Fixes
@@ -104,6 +104,7 @@ public class ExchangeLatchManager {
// First coordinator initialization.
ctx.discovery().localJoinFuture().listen(f -> {
+ if (f.error() == null)
this.coordinator = getLatchCoordinator(AffinityTopologyVersion.NONE);
});
