Merge pull request #47 from ozontech/fix-fd-leak

[fd-fix] add file close in maintenanceJob
ozontech · Feb 16, 2022 · 26bb487 · 26bb487
2 parents 51bda38 + fd36b52
commit 26bb487
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugin/input/file/provider.go b/plugin/input/file/provider.go
@@ -646,7 +646,9 @@ func (jp *jobProvider) maintenanceJob(job *Job) int {
 	newInode := getInode(stat)
 	if newInode != inode {
 		jp.deleteJobAndUnlock(job)
-
+		if err = file.Close(); err != nil {
+			jp.logger.Errorf("can't close file %s %v in case of different inodes", filename, err)
+		}
 		return maintenanceResultDeleted
 	}