diff --git a/pkg/storage/unified/sql/backend.go b/pkg/storage/unified/sql/backend.go index 75ec7806eb6..ae70e141219 100644 --- a/pkg/storage/unified/sql/backend.go +++ b/pkg/storage/unified/sql/backend.go @@ -546,7 +546,9 @@ func (b *backend) poller(ctx context.Context, since groupResourceRV, stream chan t.Reset(interval) continue } - since[group][resource] = next + if next > since[group][resource] { + since[group][resource] = next + } } }