[improve][metadataStore] Update namespace policies would cause metada…

…ta-store thread waiting too long (apache#16438)
wuxuanqicn · Jul 14, 2022 · d77708d · d77708d
1 parent 8774165
commit d77708d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -2005,7 +2005,7 @@ private void handleMetadataChanges(Notification n) {
 
     private void handleLocalPoliciesUpdates(NamespaceName namespace) {
         pulsar.getPulsarResources().getLocalPolicies().getLocalPoliciesAsync(namespace)
-                .thenAccept(optLocalPolicies -> {
+                .thenAcceptAsync(optLocalPolicies -> {
                     if (!optLocalPolicies.isPresent()) {
                         return;
                     }
@@ -2028,12 +2028,12 @@ private void handleLocalPoliciesUpdates(NamespaceName namespace) {
                             });
                         }
                     });
-                });
+                }, pulsar.getExecutor());
     }
 
     private void handlePoliciesUpdates(NamespaceName namespace) {
         pulsar.getPulsarResources().getNamespaceResources().getPoliciesAsync(namespace)
-                .thenAccept(optPolicies -> {
+                .thenAcceptAsync(optPolicies -> {
                     if (!optPolicies.isPresent()) {
                         return;
                     }
@@ -2058,7 +2058,7 @@ private void handlePoliciesUpdates(NamespaceName namespace) {
                     // sometimes, some brokers don't receive policies-update watch and miss to remove
                     // replication-cluster and still own the bundle. That can cause data-loss for TODO: git-issue
                     unloadDeletedReplNamespace(policies, namespace);
-                });
+                }, pulsar.getExecutor());
     }
 
     private void handleDynamicConfigurationUpdates() {