diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java index 00b6dfa00d3084..99a53e7d967bcb 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java @@ -422,14 +422,7 @@ private void handleReleaseEvent(String serviceUnit, ServiceUnitStateData data) { private void handleSplitEvent(String serviceUnit, ServiceUnitStateData data) { if (isTargetBroker(data.broker())) { splitServiceUnit(serviceUnit, data) - .whenComplete((__, e) -> { - if (e != null) { - // When has exception, change the bundle state back to Splitting -> Owned . - pubAsync(serviceUnit, new ServiceUnitStateData(Owned, data.broker(), data.sourceBroker())); - log(e, serviceUnit, data, null); - } - - }); + .whenComplete((__, e) -> log(e, serviceUnit, data, null)); } }