Skip to content
This repository has been archived by the owner on Nov 24, 2023. It is now read-only.

Commit

Permalink
sycner: address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
csuzhangxc committed Apr 28, 2020
1 parent 0c5d865 commit 846c6b5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion syncer/checkpoint.go
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ func (b *binlogPoint) rollback(schemaTracker *schema.Tracker, schema string) (is
// if any of them are not equal, then we rollback them:
// - set the one in the checkpoint but not flushed to the one flushed.
// - set the one tracked to the one in the checkpoint by the caller of this method (both flushed and not flushed are the same now)
if isSchemaChanged = trackedTi != b.ti || b.ti != b.flushedTI; isSchemaChanged {
if isSchemaChanged = (trackedTi != b.ti) || (b.ti != b.flushedTI); isSchemaChanged {
b.ti = b.flushedTI
}
return
Expand Down

0 comments on commit 846c6b5

Please sign in to comment.