Skip to content

Commit

Permalink
Fetcher: add new lister that validates, but buffers files in blocks
Browse files Browse the repository at this point in the history
  • Loading branch information
MichaHoffmann committed Apr 17, 2024
1 parent 1b72837 commit c4f8a52
Show file tree
Hide file tree
Showing 4 changed files with 196 additions and 116 deletions.
2 changes: 1 addition & 1 deletion CHANGELOG.md
Expand Up @@ -39,7 +39,7 @@ We use *breaking :warning:* to mark changes that are not backward compatible (re

- [#7123](https://github.com/thanos-io/thanos/pull/7123) Rule: Change default Alertmanager API version to v2.
- [#7223](https://github.com/thanos-io/thanos/pull/7223) Automatic detection of memory limits and configure GOMEMLIMIT to match.
- [#7282](https://github.com/thanos-io/thanos/pull/7282) Fetcher: mark metas with incomplete files as corrupted.
- [#7282](https://github.com/thanos-io/thanos/pull/7282) Fetcher: mark metas with incomplete files as partial if configured.
- [#7282](https://github.com/thanos-io/thanos/pull/7282) Compactor: add flag to disable cleanup of partial uploads

### Removed
Expand Down
7 changes: 3 additions & 4 deletions cmd/thanos/compact.go
Expand Up @@ -419,7 +419,7 @@ func runCompact(
var cleanMtx sync.Mutex
// TODO(GiedriusS): we could also apply retention policies here but the logic would be a bit more complex.
cleanPartialMarked := func() error {
if !conf.cleanupPartialUploads {
if conf.disableCleanupPartialUploads {
level.Info(logger).Log("msg", "cleanup of partial uploads is disabled, skipping")
return nil
}
Expand Down Expand Up @@ -728,7 +728,7 @@ type compactConfig struct {
progressCalculateInterval time.Duration
filterConf *store.FilterConfig
disableAdminOperations bool
cleanupPartialUploads bool
disableCleanupPartialUploads bool
}

func (cc *compactConfig) registerFlag(cmd extkingpin.FlagClause) {
Expand Down Expand Up @@ -842,6 +842,5 @@ func (cc *compactConfig) registerFlag(cmd extkingpin.FlagClause) {
cmd.Flag("bucket-web-label", "External block label to use as group title in the bucket web UI").StringVar(&cc.label)

cmd.Flag("disable-admin-operations", "Disable UI/API admin operations like marking blocks for deletion and no compaction.").Default("false").BoolVar(&cc.disableAdminOperations)
cmd.Flag("compact.cleanup-partial-uploads", "Enable cleanup of partial uploads").
Hidden().Default("true").BoolVar(&cc.cleanupPartialUploads)
cmd.Flag("compact.disable-cleanup-partial-uploads", "Disable cleanup of partial uploads.").Default("false").BoolVar(&cc.disableCleanupPartialUploads)
}

0 comments on commit c4f8a52

Please sign in to comment.