diff --git a/binlog.c b/binlog.c index 651957a..3ede5e5 100644 --- a/binlog.c +++ b/binlog.c @@ -156,6 +156,7 @@ static int fetch_comb_binlog_set_qts (void *extra) { static int fetch_comb_binlog_set_date (void *extra) { int new_date = fetch_int (); + if (new_date < tgl_state.date) { return; } assert (new_date >= tgl_state.date); tgl_state.date = new_date; return 0;