From b4cee1b102585367b2a1e72a4e587b00a13890ab Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=81=BC=E5=8D=8E?=
 <43363120+BurningCN@users.noreply.github.com>
Date: Tue, 20 Apr 2021 11:54:35 +0800
Subject: [PATCH] [ISSUE #2821] Overriding the ServiceThread#shutdown in
 HAClient class

---
 .../main/java/org/apache/rocketmq/store/ha/HAService.java  | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
index a0e77fa3..34c51eb9 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
@@ -590,6 +590,13 @@ public class HAService {
 
             log.info(this.getServiceName() + " service end");
         }
+
+        @Override
+        public void shutdown() {
+            super.shutdown();
+            closeMaster();
+        }
+
         // private void disableWriteFlag() {
         // if (this.socketChannel != null) {
         // SelectionKey sk = this.socketChannel.keyFor(this.selector);
-- 
GitLab