<BUG>U.log(log, "Starting caches rebalancing [top=" + exchFut.topologyVersion() + "]");if (marshR != null)</BUG><CONTEXT>if (asyncStartFut != null)asyncStartFut.get(); // Wait for thread stop.rebalanceQ.addAll(orderedRs);if (marshR != null || !rebalanceQ.isEmpty()) {if (futQ.isEmpty()) {<extra_id_0>try {marshR.call(); //Marshaller cache rebalancing launches in sync way.}</CONTEXT>
U.log(log, "Rebalancing required" +"[top=" + exchFut.topologyVersion() + ", evt=" + exchFut.discoveryEvent().name() +", node=" + exchFut.discoveryEvent().node().id() + ']');if (marshR != null)