Merge pull request #16423 from chenyang8094/fix-raftexample-panic-whe…

…n-reduce-snapshot-count Handle ErrCompacted errors for Compact in raftexample
etcd-io · Aug 18, 2023 · 39aad38 · 39aad38
2 parents 6ef9c53 + 68db708
commit 39aad38
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/contrib/raftexample/raft.go b/contrib/raftexample/raft.go
@@ -392,10 +392,13 @@ func (rc *raftNode) maybeTriggerSnapshot(applyDoneC <-chan struct{}) {
 		compactIndex = rc.appliedIndex - snapshotCatchUpEntriesN
 	}
 	if err := rc.raftStorage.Compact(compactIndex); err != nil {
-		panic(err)
+		if err != raft.ErrCompacted {
+			panic(err)
+		}
+	} else {
+		log.Printf("compacted log at index %d", compactIndex)
 	}
 
-	log.Printf("compacted log at index %d", compactIndex)
 	rc.snapshotIndex = rc.appliedIndex
 }