diff --git a/pkg/ingester/stream.go b/pkg/ingester/stream.go index 71f4958708db69a5e541ab37509b4bc8e7f21b1e..88ea0166e768c5c3bdf4cc5ab0190a12b4e6d086 100644 --- a/pkg/ingester/stream.go +++ b/pkg/ingester/stream.go @@ -94,7 +94,7 @@ func (s *stream) Push(_ context.Context, entries []logproto.Entry) error { if err := chunk.chunk.Append(&entries[i]); err != nil { appendErr = err } - chunk.lastUpdated = entries[i].Timestamp + chunk.lastUpdated = time.Now() } if appendErr == chunkenc.ErrOutOfOrder {