From a9a7ec141532d1c0af6d2c94a1ab3d48b4c70a54 Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Mon, 15 Sep 2025 16:23:00 -0400 Subject: [PATCH] Close DB before reopening --- store/store.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/store/store.go b/store/store.go index 46ed1de7..f159683e 100644 --- a/store/store.go +++ b/store/store.go @@ -2194,6 +2194,12 @@ func (s *Store) fsmApply(l *raft.Log) (e any) { // that the node is part of a cluster, so we must delete the existing database // file and let it be rebuilt from the Raft log. var err error + if s.db != nil { + if err := s.db.Close(); err != nil { + s.logger.Fatalf("failed to close stale database: %s", err) + } + s.db = nil + } s.db, err = openOnDisk(s.dbPath, s.dbDrv, s.dbConf.FKConstraints, true) if err != nil { s.logger.Fatalf("failed to reopen database: %s", err)