diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-25 13:40:19 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-03-25 13:40:19 +0500 |
| commit | c1450bf9fe59d304e94a7dee8051d8c02670edc4 (patch) | |
| tree | 1b16ac0bad4c78b478be1815566e77d49e5fd941 /weed/server/raft_server.go | |
| parent | e48764be75d285fe7edfbd88ca7ff419580c48d1 (diff) | |
| download | seaweedfs-c1450bf9fe59d304e94a7dee8051d8c02670edc4.tar.xz seaweedfs-c1450bf9fe59d304e94a7dee8051d8c02670edc4.zip | |
always clear previous log to avoid server is promotable
https://github.com/chrislusf/seaweedfs/issues/2804
Diffstat (limited to 'weed/server/raft_server.go')
| -rw-r--r-- | weed/server/raft_server.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go index 91dd185c8..16afb5c7d 100644 --- a/weed/server/raft_server.go +++ b/weed/server/raft_server.go @@ -81,10 +81,11 @@ func NewRaftServer(option *RaftServerOption) (*RaftServer, error) { transporter := raft.NewGrpcTransporter(option.GrpcDialOption) glog.V(0).Infof("Starting RaftServer with %v", option.ServerAddr) + // always clear previous log to avoid server is promotable + os.RemoveAll(path.Join(s.dataDir, "log")) if !option.RaftResumeState { // always clear previous metadata os.RemoveAll(path.Join(s.dataDir, "conf")) - os.RemoveAll(path.Join(s.dataDir, "log")) os.RemoveAll(path.Join(s.dataDir, "snapshot")) } if err := os.MkdirAll(path.Join(s.dataDir, "snapshot"), 0600); err != nil { |