diff --git a/storage/metric/watermark.go b/storage/metric/watermark.go index c58fb0ce0e..040619ff2c 100644 --- a/storage/metric/watermark.go +++ b/storage/metric/watermark.go @@ -119,7 +119,7 @@ func (lru *WatermarkCache) Clear() { } func (lru *WatermarkCache) updateInplace(e *list.Element, w *Watermarks) { - e.Value = w + e.Value.(*entry).watermarks = w lru.moveToFront(e) lru.checkCapacity() }