(fluss) branch main updated: [server] Close ZooKeeperClient only after all dependent components have been shut down to prevent exceptions (#2023)

[yunhong]

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

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new cc498bf42 [server] Close ZooKeeperClient only after all dependent 
components have been shut down to prevent exceptions (#2023)
cc498bf42 is described below

commit cc498bf4245002c08ad8f80b2ff37f71ee4cbc0a
Author: Liebing <44154062+liebin...@users.noreply.github.com>
AuthorDate: Wed Nov 26 11:56:49 2025 +0800

    [server] Close ZooKeeperClient only after all dependent components have 
been shut down to prevent exceptions (#2023)
    
    Co-authored-by: Liebing <yuliebing....@alibaba-inc.com>
---
 .../fluss/server/coordinator/CoordinatorServer.java      | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorServer.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorServer.java
index 03e0bed92..e3a10a730 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorServer.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorServer.java
@@ -424,14 +424,6 @@ public class CoordinatorServer extends ServerBase {
                 exception = ExceptionUtils.firstOrSuppressed(t, exception);
             }
 
-            try {
-                if (zkClient != null) {
-                    zkClient.close();
-                }
-            } catch (Throwable t) {
-                exception = ExceptionUtils.firstOrSuppressed(t, exception);
-            }
-
             try {
                 if (authorizer != null) {
                     authorizer.close();
@@ -452,6 +444,14 @@ public class CoordinatorServer extends ServerBase {
                 exception = ExceptionUtils.firstOrSuppressed(t, exception);
             }
 
+            try {
+                if (zkClient != null) {
+                    zkClient.close();
+                }
+            } catch (Throwable t) {
+                exception = ExceptionUtils.firstOrSuppressed(t, exception);
+            }
+
             try {
                 if (rpcClient != null) {
                     rpcClient.close();