fix influxd close and reset issue

chengshiwen · Sep 7, 2024 · 61d0b10 · 61d0b10
1 parent 5ce4d08
commit 61d0b10
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/cmd/influxd/run/server.go b/cmd/influxd/run/server.go
@@ -547,6 +547,10 @@ func (s *Server) Close() error {
 
 	s.config.deregisterDiagnostics(s.Monitor)
 
+	if s.ShardWriter != nil {
+		s.ShardWriter.Close()
+	}
+
 	if s.PointsWriter != nil {
 		s.PointsWriter.Close()
 	}
@@ -555,6 +559,10 @@ func (s *Server) Close() error {
 		s.HintedHandoff.Close()
 	}
 
+	if s.MetaExecutor != nil {
+		s.MetaExecutor.Close()
+	}
+
 	if s.QueryExecutor != nil {
 		s.QueryExecutor.Close()
 	}
@@ -600,7 +608,9 @@ func (s *Server) Reset() error {
 	s.closing = svr.closing
 	s.MetaClient = svr.MetaClient
 	s.TSDBStore = svr.TSDBStore
+	s.ClusterStore = svr.ClusterStore
 	s.QueryExecutor = svr.QueryExecutor
+	s.MetaExecutor = svr.MetaExecutor
 	s.PointsWriter = svr.PointsWriter
 	s.ShardWriter = svr.ShardWriter
 	s.HintedHandoff = svr.HintedHandoff