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

Skip onFileStoreReplace with tsi

pull/8856/head
Jason Wilder 2017-09-19 13:02:52 -06:00
parent 4fe81aeee6
commit 0d52b060df
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tsdb/engine/tsm1/engine.go
View File

@ -26,6 +26,7 @@ import (
"github.com/influxdata/influxdb/tsdb"
_ "github.com/influxdata/influxdb/tsdb/index"
"github.com/influxdata/influxdb/tsdb/index/inmem"
"github.com/influxdata/influxdb/tsdb/index/tsi1"
"github.com/uber-go/zap"
)
@ -1289,6 +1290,10 @@ func (e *Engine) compactTSMFull(quit <-chan struct{}) {
// onFileStoreReplace is callback handler invoked when the FileStore
// has replaced one set of TSM files with a new set.
func (e *Engine) onFileStoreReplace(newFiles []TSMFile) {
if e.index.Type() == tsi1.IndexName {
return
}
// Load any new series keys to the index
readers := make([]chan seriesKey, 0, len(newFiles))
for _, r := range newFiles {