Fix test

Signed-off-by: Zixuan Liu <[email protected]>
ascentstream · Jul 23, 2024 · 0351af1 · 0351af1
1 parent 580af14
commit 0351af1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceServiceTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/namespace/NamespaceServiceTest.java
@@ -42,6 +42,7 @@
 import java.util.Optional;
 import java.util.Set;
 import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import lombok.Cleanup;
@@ -819,7 +820,7 @@ private void waitResourceDataUpdateToZK(LoadManager loadManager) throws Exceptio
         // Wait until "ModularLoadManager" completes processing the ZK notification.
         ModularLoadManagerWrapper modularLoadManagerWrapper = (ModularLoadManagerWrapper) loadManager;
         ModularLoadManagerImpl modularLoadManager = (ModularLoadManagerImpl) modularLoadManagerWrapper.getLoadManager();
-        ScheduledExecutorService scheduler = Whitebox.getInternalState(modularLoadManager, "scheduler");
+        ExecutorService scheduler = Whitebox.getInternalState(modularLoadManager, "executors");
         CompletableFuture<Void> waitForNoticeHandleFinishByLoadManager = new CompletableFuture<>();
         scheduler.execute(() -> {
             waitForNoticeHandleFinishByLoadManager.complete(null);