diff --git a/pkg/block/block.go b/pkg/block/block.go index 8c6d4a4b2fe..5edf27f2423 100644 --- a/pkg/block/block.go +++ b/pkg/block/block.go @@ -416,7 +416,7 @@ func MarkForNoDownsample(ctx context.Context, logger log.Logger, bkt objstore.Bu } noDownsampleMark, err := json.Marshal(metadata.NoDownsampleMark{ ID: id, - Version: metadata.NoCompactMarkVersion1, + Version: metadata.NoDownsampleMarkVersion1, NoDownsampleTime: time.Now().Unix(), Reason: reason, diff --git a/pkg/block/metadata/markers.go b/pkg/block/metadata/markers.go index 88b9b8d911c..1576b1748ac 100644 --- a/pkg/block/metadata/markers.go +++ b/pkg/block/metadata/markers.go @@ -31,6 +31,8 @@ const ( DeletionMarkVersion1 = 1 // NoCompactMarkVersion1 is the version of no-compact-mark file supported by Thanos. NoCompactMarkVersion1 = 1 + // NoDownsampleVersion1 is the version of no-downsample-mark file supported by Thanos. + NoDownsampleMarkVersion1 = 1 ) var ( diff --git a/pkg/compact/downsample/downsample.go b/pkg/compact/downsample/downsample.go index 9a35ce1914c..f1b595d3b5b 100644 --- a/pkg/compact/downsample/downsample.go +++ b/pkg/compact/downsample/downsample.go @@ -759,7 +759,7 @@ func NewGatherNoDownsampleMarkFilter(logger log.Logger, bkt objstore.Instrumente } } -// NoDownsampleMarkedBlocks returns block ids that were marked for no downsample +// NoDownsampleMarkedBlocks returns block ids that were marked for no downsample. func (f *GatherNoDownsampleMarkFilter) NoCompactMarkedBlocks() map[ulid.ULID]*metadata.NoDownsampleMark { f.mtx.Lock() copiedNoDownsampleMarked := make(map[ulid.ULID]*metadata.NoDownsampleMark, len(f.noDownsampleMarkedMap))