Skip to content

Commit

Permalink
snapshot.go: resolve conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
wlwilliamx committed Dec 20, 2024
1 parent c5111c7 commit d132f4f
Showing 1 changed file with 0 additions and 21 deletions.
21 changes: 0 additions & 21 deletions cdc/entry/schema/snapshot.go
Original file line number Diff line number Diff line change
Expand Up @@ -109,27 +109,6 @@ func (s *Snapshot) FillSchemaName(job *timodel.Job) error {
return nil
}

<<<<<<< HEAD
// GetSchemaVersion returns the schema version of the meta.
func GetSchemaVersion(meta *timeta.Meta) (int64, error) {
// After we get the schema version at startTs, if the diff corresponding to that version does not exist,
// it means that the job is not committed yet, so we should subtract one from the version, i.e., version--.
version, err := meta.GetSchemaVersion()
if err != nil {
return 0, errors.Trace(err)
}
diff, err := meta.GetSchemaDiff(version)
if err != nil {
return 0, errors.Trace(err)
}
if diff == nil {
version--
}
return version, nil
}

=======
>>>>>>> c5b8800f8e (schemaStorage(ticdc): remove `schemaVersion` in `schemaStorage` (#11869))
// NewSnapshotFromMeta creates a schema snapshot from meta.
func NewSnapshotFromMeta(
id model.ChangeFeedID,
Expand Down

0 comments on commit d132f4f

Please sign in to comment.