Skip to content

Commit 9a447fd

Browse files
authored
Actually set the chunk-age-jitter to 0 (#2364)
Signed-off-by: Goutham Veeramachaneni <[email protected]>
1 parent 15b2e6c commit 9a447fd

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

docs/configuration/config-file-reference.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -577,7 +577,7 @@ lifecycler:
577577
578578
# Range of time to subtract from -ingester.max-chunk-age to spread out flushes
579579
# CLI flag: -ingester.chunk-age-jitter
580-
[chunk_age_jitter: <duration> | default = 20m0s]
580+
[chunk_age_jitter: <duration> | default = 0s]
581581
582582
# Number of concurrent goroutines flushing to dynamodb.
583583
# CLI flag: -ingester.concurrent-flushes

pkg/ingester/ingester.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ func (cfg *Config) RegisterFlags(f *flag.FlagSet) {
8484
f.DurationVar(&cfg.MaxChunkIdle, "ingester.max-chunk-idle", 5*time.Minute, "Maximum chunk idle time before flushing.")
8585
f.DurationVar(&cfg.MaxStaleChunkIdle, "ingester.max-stale-chunk-idle", 2*time.Minute, "Maximum chunk idle time for chunks terminating in stale markers before flushing. 0 disables it and a stale series is not flushed until the max-chunk-idle timeout is reached.")
8686
f.DurationVar(&cfg.MaxChunkAge, "ingester.max-chunk-age", 12*time.Hour, "Maximum chunk age before flushing.")
87-
f.DurationVar(&cfg.ChunkAgeJitter, "ingester.chunk-age-jitter", 20*time.Minute, "Range of time to subtract from -ingester.max-chunk-age to spread out flushes")
87+
f.DurationVar(&cfg.ChunkAgeJitter, "ingester.chunk-age-jitter", 0, "Range of time to subtract from -ingester.max-chunk-age to spread out flushes")
8888
f.BoolVar(&cfg.SpreadFlushes, "ingester.spread-flushes", true, "If true, spread series flushes across the whole period of -ingester.max-chunk-age.")
8989
f.IntVar(&cfg.ConcurrentFlushes, "ingester.concurrent-flushes", 50, "Number of concurrent goroutines flushing to dynamodb.")
9090
f.DurationVar(&cfg.RateUpdatePeriod, "ingester.rate-update-period", 15*time.Second, "Period with which to update the per-user ingestion rates.")

0 commit comments

Comments
 (0)