This is an automated email from the ASF dual-hosted git repository.
czy006 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new 79f1beaf8 [AMORO-3132]High available service should not close curator
client before LeaderLatch closing (#3133)
79f1beaf8 is described below
commit 79f1beaf86a7a4cc4335717c9a2e8d50ef7b7a54
Author: Nico CHen <[email protected]>
AuthorDate: Tue Aug 27 19:18:35 2024 +0800
[AMORO-3132]High available service should not close curator client before
LeaderLatch closing (#3133)
[AMORO-3132][Bug]:High available service should not curator client before
LeaderLatch closing #3132
---
.../main/java/org/apache/amoro/server/HighAvailabilityContainer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/HighAvailabilityContainer.java
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/HighAvailabilityContainer.java
index 5d10b1a2d..76fb83d49 100644
---
a/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/HighAvailabilityContainer.java
+++
b/amoro-ams/amoro-ams-server/src/main/java/org/apache/amoro/server/HighAvailabilityContainer.java
@@ -122,8 +122,8 @@ public class HighAvailabilityContainer implements
LeaderLatchListener {
public void close() {
if (leaderLatch != null) {
try {
- this.zkClient.close();
this.leaderLatch.close();
+ this.zkClient.close();
} catch (IOException e) {
LOG.error("Close high availability services failed", e);
}