Complete future after Leadership withdraw is done
Change-Id: I905a78c3f80e10793506ac92783d502798ae0390
Showing
1 changed file
with
1 additions
and
0 deletions
... | @@ -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); | ... | ... |
-
Please register or login to post a comment