diff --git a/src/coordinator/raft_server.go b/src/coordinator/raft_server.go index c39ec912af..f85fedb823 100644 --- a/src/coordinator/raft_server.go +++ b/src/coordinator/raft_server.go @@ -316,7 +316,7 @@ func (s *RaftServer) CompactLog() { func (s *RaftServer) CommittedAllChanges() bool { entries := s.raftServer.LogEntries() - if len(entries) == 0 { + if s.raftServer.CommitIndex() == 0 { return false } lastIndex := entries[len(entries)-1].Index()