Madan Jampani
Committed by Brian O'Connor

Complete future after Leadership withdraw is done

Change-Id: I905a78c3f80e10793506ac92783d502798ae0390
...@@ -289,6 +289,7 @@ public class DistributedLeadershipManager implements LeadershipService { ...@@ -289,6 +289,7 @@ public class DistributedLeadershipManager implements LeadershipService {
289 (topic, candidates) -> candidates.stream() 289 (topic, candidates) -> candidates.stream()
290 .filter(nodeId -> !localNodeId.equals(nodeId)) 290 .filter(nodeId -> !localNodeId.equals(nodeId))
291 .collect(Collectors.toList())); 291 .collect(Collectors.toList()));
292 + future.complete(null);
292 } catch (Exception e) { 293 } catch (Exception e) {
293 log.debug("Failed to verify (and clear) any lock this node might be holding for {}", path, e); 294 log.debug("Failed to verify (and clear) any lock this node might be holding for {}", path, e);
294 retryWithdraw(path, future); 295 retryWithdraw(path, future);
......