fix(tsi): sync index file before close (influxdata#21932)

chengshiwen · Aug 11, 2024 · ed80518 · ed80518
1 parent 4c4ac1f
commit ed80518
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/tsdb/index/tsi1/partition.go b/tsdb/index/tsi1/partition.go
@@ -1006,6 +1006,11 @@ func (p *Partition) compactToLevel(files []*IndexFile, level int, interrupt <-ch
 		return
 	}
 
+	if err = f.Sync(); err != nil {
+		log.Error("Error sync index file", zap.Error(err))
+		return
+	}
+
 	// Close file.
 	if err := f.Close(); err != nil {
 		log.Error("Error closing index file", zap.Error(err))
@@ -1151,9 +1156,14 @@ func (p *Partition) compactLogFile(logFile *LogFile) {
 		return
 	}
 
+	if err = f.Sync(); err != nil {
+		log.Error("Cannot sync index file", zap.Error(err))
+		return
+	}
+
 	// Close file.
 	if err := f.Close(); err != nil {
-		log.Error("Cannot close log file", zap.Error(err))
+		log.Error("Cannot close index file", zap.Error(err))
 		return
 	}