(pulsar) branch master updated: [fix][fn] Reorder Function Worker shutdown to stop scheduler before runtime manager (#26136)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 7a40adad02c [fix][fn] Reorder Function Worker shutdown to stop 
scheduler before runtime manager (#26136)
7a40adad02c is described below

commit 7a40adad02c11130a90e178e8b3aaed996fcacbb
Author: Dream95 <864197...@qq.com>
AuthorDate: Fri Jul 3 02:48:21 2026 +0800

    [fix][fn] Reorder Function Worker shutdown to stop scheduler before runtime 
manager (#26136)
    
    Signed-off-by: Dream95 <zhou_8...@163.com>
---
 .../pulsar/functions/worker/PulsarWorkerService.java     | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
index 5e3e008cc08..6c96ba48873 100644
--- 
a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
+++ 
b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java
@@ -636,14 +636,6 @@ public class PulsarWorkerService implements WorkerService {
             }
         }
 
-        if (null != functionRuntimeManager) {
-            try {
-                functionRuntimeManager.close();
-            } catch (Exception e) {
-                log.warn().exception(e).log("Failed to close function runtime 
manager");
-            }
-        }
-
         if (null != clusterServiceCoordinator) {
             clusterServiceCoordinator.close();
         }
@@ -656,6 +648,14 @@ public class PulsarWorkerService implements WorkerService {
             schedulerManager.close();
         }
 
+        if (null != functionRuntimeManager) {
+            try {
+                functionRuntimeManager.close();
+            } catch (Exception e) {
+                log.warn().exception(e).log("Failed to close function runtime 
manager");
+            }
+        }
+
         if (null != leaderService) {
             try {
                 leaderService.close();