Merge pull request #14246 from influxdata/mu-tsm-clean-14058

Clears tsm files when replace fails
influxdata · Aug 7, 2019 · 62d1474 · 62d1474
2 parents 757fb4f + fe2aceb
commit 62d1474
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/tsdb/tsm1/engine.go b/tsdb/tsm1/engine.go
@@ -1185,6 +1185,14 @@ func (s *compactionStrategy) compactGroup(ctx context.Context) {
 		log.Info("Error replacing new TSM files", zap.Error(err))
 		s.tracker.Attempted(s.level, false, "", 0)
 		time.Sleep(time.Second)
+
+		// Remove the new snapshot files. We will try again.
+		for _, file := range files {
+			if err := os.Remove(file); err != nil {
+				log.Error("Unable to remove file", zap.String("path", file), zap.Error(err))
+			}
+		}
+
 		return
 	}