From eb6215acbfb32186f9cfc79cf4fc67ee47459e82 Mon Sep 17 00:00:00 2001 From: Ben Johnson Date: Thu, 29 Mar 2018 14:27:28 -0600 Subject: [PATCH] Fix buildtsi partition key. --- cmd/influx_inspect/buildtsi/buildtsi.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/influx_inspect/buildtsi/buildtsi.go b/cmd/influx_inspect/buildtsi/buildtsi.go index 897472075a3..b1bcf345c84 100644 --- a/cmd/influx_inspect/buildtsi/buildtsi.go +++ b/cmd/influx_inspect/buildtsi/buildtsi.go @@ -207,7 +207,7 @@ func (cmd *Command) processShard(sfile *tsdb.SeriesFile, dbName, rpName string, cmd.Logger.Info("series", zap.String("name", string(name)), zap.String("tags", tags.String())) } - if err := tsiIndex.CreateSeriesIfNotExists(nil, []byte(name), tags); err != nil { + if err := tsiIndex.CreateSeriesIfNotExists(seriesKey, []byte(name), tags); err != nil { return fmt.Errorf("cannot create series: %s %s (%s)", name, tags.String(), err) } } @@ -251,7 +251,7 @@ func (cmd *Command) processTSMFile(index *tsi1.Index, path string) error { cmd.Logger.Info("series", zap.String("name", string(name)), zap.String("tags", tags.String())) } - if err := index.CreateSeriesIfNotExists(nil, []byte(name), tags); err != nil { + if err := index.CreateSeriesIfNotExists(seriesKey, []byte(name), tags); err != nil { return fmt.Errorf("cannot create series: %s %s (%s)", name, tags.String(), err) } }