Update RAFT checkpoint when doing a clean shutdown. (#5097)

dgraph-io · Apr 7, 2020 · 98769a6 · 98769a6
1 parent f38073a
commit 98769a6
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/worker/worker.go b/worker/worker.go
@@ -112,6 +112,12 @@ func BlockingStop() {
 	glog.Infof("Stopping group...")
 	groups().closer.SignalAndWait()
 
+	// Update checkpoint so that proposals are not replayed after the server restarts.
+	glog.Infof("Updating RAFT state before shutting down...")
+	if err := groups().Node.updateRaftProgress(); err != nil {
+		glog.Warningf("Error while updating RAFT progress before shutdown: %v", err)
+	}
+
 	glog.Infof("Stopping node...")
 	groups().Node.closer.SignalAndWait()