You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by yu...@apache.org on 2025/11/26 03:56:53 UTC
(fluss) branch main updated: [server] Close ZooKeeperClient only after all dependent components have been shut down to prevent exceptions (#2023)
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 <44...@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 <yu...@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();