Backward compatibility fix - Fixes
@@ -1508,7 +1508,7 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
releaseLatch.countDown();
// For compatibility with old version where joining nodes are not waiting for latch.
- if (!cctx.exchange().latch().canSkipJoiningNodes(initialVersion()))
+ if (localJoinExchange() && !cctx.exchange().latch().canSkipJoiningNodes(initialVersion()))
return;
try {
@@ -2543,7 +2543,6 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
}
}
}
-
if (allReceived) {
if (!awaitSingleMapUpdates())
return;
