Revert handle exception

Demogorgon314 · Jan 4, 2023 · e97ca14 · e97ca14
1 parent 7f68d72
commit e97ca14
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/.../org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java b/.../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));
         }
     }