From e97ca143129dbb158170c881fae998218bc028bf Mon Sep 17 00:00:00 2001
From: Demogorgon314 <kwang@streamnative.io>
Date: Wed, 4 Jan 2023 11:24:00 +0800
Subject: [PATCH] Revert handle exception

---
 .../extensions/channel/ServiceUnitStateChannelImpl.java  | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

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));
         }
     }