From 2359bfe5a67f98072f6fc24a6bfe9a576822f636 Mon Sep 17 00:00:00 2001 From: Bartek Plotka Date: Tue, 17 Apr 2018 01:12:43 +0100 Subject: [PATCH] Added missing finalizer. Signed-off-by: Bartek Plotka --- pkg/verifier/separated_blocks.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/verifier/separated_blocks.go b/pkg/verifier/separated_blocks.go index 9175e15fcdc..3600f0e72dd 100644 --- a/pkg/verifier/separated_blocks.go +++ b/pkg/verifier/separated_blocks.go @@ -132,8 +132,12 @@ func SeparatedBlocks(ctx context.Context, logger log.Logger, bkt objstore.Bucket return errors.Wrapf(err, "merge blocks %s and %s", a.ULID, b.ULID) } + if _, err := block.Finalize(path.Join(tmpdir, resid.String()), bmeta.Thanos.Labels, bmeta.Thanos.Downsample.Resolution, nil); err != nil { + return errors.Wrapf(err, "finalizing of %s failed", resid) + } + level.Info(logger).Log("msg", "uploading merged block", "newID", resid, "issue", SeparatedBlocksID) - err = objstore.UploadDir(ctx, bkt, filepath.Join(tmpdir, resid.String()), resid.String()) + err = block.Upload(ctx, bkt, filepath.Join(tmpdir, resid.String())) if err != nil { return errors.Wrapf(err, "upload of %s failed", resid) }