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 5d10b1a2d6..76fb83d492 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 void waitFollowerShip() throws Exception { 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); }