resolved comment

apache · Mar 9, 2023 · 0d88959 · 0d88959
1 parent 02c9274
commit 0d88959
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/...r/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/SplitManager.java b/...r/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/SplitManager.java
@@ -85,10 +85,11 @@ public CompletableFuture<Void> waitAsync(CompletableFuture<Void> eventPubFuture,
                     });
                     return new InFlightSplitRequest(decision, future);
                 }).future)
-                .exceptionally(e -> {
-                    log.error("Failed to publish the bundle split event for bundle:{}. Skipping wait.", bundle);
-                    counter.update(Failure, Unknown);
-                    return null;
+                .whenComplete((__, ex) -> {
+                    if (ex != null) {
+                        log.error("Failed to publish the bundle split event for bundle:{}. Skipping wait.", bundle);
+                        counter.update(Failure, Unknown);
+                    }
                 });
     }