Skip to content

Commit

Permalink
Change how we use checksum and row comparison
Browse files Browse the repository at this point in the history
  • Loading branch information
michaelmdeng authored and Michael Deng committed May 4, 2024
1 parent d28ee6c commit a787fbd
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sync_diff_inspector/diff.go
Original file line number Diff line number Diff line change
Expand Up @@ -437,7 +437,7 @@ func (df *Diff) consume(ctx context.Context, rangeInfo *splitter.RangeInfo) bool
// If an error occurs during the checksum phase, skip the data compare phase.
state = checkpoints.FailedState
df.report.SetTableMeetError(schema, table, err)
} else if !isEqual && df.exportFixSQL {
} else if isEqual || df.exportFixSQL {
state = checkpoints.FailedState
// if the chunk's checksum differ, try to do binary check
info := rangeInfo
Expand Down

0 comments on commit a787fbd

Please sign in to comment.