Skip to content

Commit

Permalink
treat ClusterVersionSet as 3.5 version
Browse files Browse the repository at this point in the history
Signed-off-by: Benjamin Wang <[email protected]>
  • Loading branch information
ahrtr committed Jan 23, 2025
1 parent 32cfd45 commit 8ac3f51
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions server/storage/wal/version.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,11 +113,12 @@ func visitEntryData(entryType raftpb.EntryType, data []byte, visitor Visitor) er
}
msg = proto.MessageReflect(&raftReq)
if raftReq.ClusterVersionSet != nil {
ver, err := semver.NewVersion(raftReq.ClusterVersionSet.Ver)
_, err := semver.NewVersion(raftReq.ClusterVersionSet.Ver)
if err != nil {
return err
}
err = visitor(msg.Descriptor().FullName(), ver)
// ClusterVersionSet was introduced in 3.5.
err = visitor(msg.Descriptor().FullName(), &version.V3_5)
if err != nil {
return err
}
Expand Down

0 comments on commit 8ac3f51

Please sign in to comment.