diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java index 1fcd0f88877..acf0c09c1bd 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/Auditor.java @@ -647,6 +647,11 @@ public void operationComplete(int rc, Set fragments) { for (LedgerFragment f : fragments) { bookies.addAll(f.getAddresses()); } + if (bookies.isEmpty()) { + // no missing fragments + callback.processResult(Code.OK, null, null); + return; + } publishSuspectedLedgersAsync( bookies.stream().map(BookieSocketAddress::toString).collect(Collectors.toList()), Sets.newHashSet(lh.getId())