diff --git a/tsdb/db.go b/tsdb/db.go index 173f6db77d..072acb9bfb 100644 --- a/tsdb/db.go +++ b/tsdb/db.go @@ -303,7 +303,7 @@ func (db *DBReadOnly) FlushWAL(dir string) error { if len(blockReaders) > 0 { maxBlockTime = blockReaders[len(blockReaders)-1].Meta().MaxTime } - w, err := wal.Open(db.logger, nil, filepath.Join(db.dir, "wal")) + w, err := wal.Open(db.logger, filepath.Join(db.dir, "wal")) if err != nil { return err } @@ -371,7 +371,7 @@ func (db *DBReadOnly) Querier(ctx context.Context, mint, maxt int64) (storage.Qu // Also add the WAL if the current blocks don't cover the requests time range. if maxBlockTime <= maxt { - w, err := wal.Open(db.logger, nil, filepath.Join(db.dir, "wal")) + w, err := wal.Open(db.logger, filepath.Join(db.dir, "wal")) if err != nil { return nil, err } diff --git a/tsdb/wal/wal.go b/tsdb/wal/wal.go index bb57975ad6..774b5f0ba5 100644 --- a/tsdb/wal/wal.go +++ b/tsdb/wal/wal.go @@ -293,7 +293,7 @@ func NewSize(logger log.Logger, reg prometheus.Registerer, dir string, segmentSi } // Open an existing WAL. -func Open(logger log.Logger, reg prometheus.Registerer, dir string) (*WAL, error) { +func Open(logger log.Logger, dir string) (*WAL, error) { if logger == nil { logger = log.NewNopLogger() }