Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Tidy up logging of compaction settings

pull/10102/head
Edd Robinson 2018-07-18 17:13:45 +01:00
parent 18e406549b
commit 55ffeb563a
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tsdb/store.go
View File

@ -235,11 +235,15 @@ func (s *Store) loadShards() error {
s.EngineOptions.CompactionLimiter = limiter.NewFixed(lim)
// Env var to disable throughput limiter. This will be moved to a config option in 1.5.
compactionSettings := []zapcore.Field{zap.Int("max_concurrent_compactions", lim)}
if os.Getenv("INFLUXDB_DATA_COMPACTION_THROUGHPUT") == "" {
rate, burst := 48*1024*1024, 48*1024*1024
s.EngineOptions.CompactionThroughputLimiter = limiter.NewRate(48*1024*1024, 48*1024*1024)
compactionSettings = append(compactionSettings, zap.Int("throughput_bytes_per_second", rate), zap.Int("throughput_burst_bytes", burst))
} else {
s.Logger.Info("Compaction throughput limit disabled")
compactionSettings = append(compactionSettings, zap.String("throughput_bytes_per_second", "unlimited"), zap.String("throughput_burst", "unlimited"))
}
s.Logger.Info("Compaction settings", compactionSettings...)
log, logEnd := logger.NewOperation(s.Logger, "Open store", "tsdb_open")
defer logEnd()