Skip to content

Commit

Permalink
mounter(ticdc): release-7.5 ignore checksum v2 (#11526)
Browse files Browse the repository at this point in the history
close #11525
  • Loading branch information
3AceShowHand authored Sep 11, 2024
1 parent 23ec8d1 commit 04bd8f6
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions cdc/entry/mounter.go
Original file line number Diff line number Diff line change
Expand Up @@ -440,6 +440,13 @@ func (m *mounter) verifyChecksum(
return 0, false, errors.New("cannot found the decoder to get the checksum")
}

version := decoder.ChecksumVersion()
if version != 0 {
log.Debug("checksum is not v1, this happens since upstream TiDB is in a higher version, ignore it",
zap.Int("version", version))
return 0, true, nil
}

// if the checksum cannot be found, which means the upstream TiDB checksum is not enabled,
// so return matched as true to skip check the event.
first, ok := decoder.GetChecksum()
Expand Down

0 comments on commit 04bd8f6

Please sign in to comment.