Skip to content

Commit

Permalink
One more.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Dec 19, 2024
1 parent dd0fb2c commit 62f69da
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion sources/mysql/streaming/dml.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ func (i *Iterator) processDML(ts time.Time, event *replication.BinlogEvent) ([]l
}

if tblAdapter.GetUnixTs() > ts.Unix() {
slog.Warn("Skipping this event since the event timestamp is older than the schema timestamp",
slog.Debug("Skipping this event since the event timestamp is older than the schema timestamp",
slog.Int64("event_ts", ts.Unix()),
slog.Int64("schema_ts", tblAdapter.GetUnixTs()),
)
Expand Down

0 comments on commit 62f69da

Please sign in to comment.