Enable forced release files of stopped container via environment vari…

…able control (#2034)
alibaba · Jan 23, 2025 · 5c8eff8 · 5c8eff8
1 parent 183af3a
commit 5c8eff8
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/plugins/input/docker/logmeta/metric_container_info.go b/plugins/input/docker/logmeta/metric_container_info.go
@@ -111,6 +111,8 @@ type InputDockerFile struct {
 	matchList                map[string]*helper.DockerInfoDetail
 	CollectingContainersMeta bool
 	firstStart               bool
+
+	forceReleaseStopContainerFile bool
 }
 
 func formatPath(path string) string {
@@ -134,6 +136,8 @@ func (idf *InputDockerFile) Name() string {
 func (idf *InputDockerFile) Init(context pipeline.Context) (int, error) {
 	idf.context = context
 
+	idf.forceReleaseStopContainerFile = os.Getenv("FORCE_RELEASE_STOP_CONTAINER_FILE") == "true"
+
 	idf.lastContainerInfoCache = make(map[string]ContainerInfoCache)
 
 	idf.firstStart = true
@@ -477,9 +481,14 @@ func (idf *InputDockerFile) Collect(collector pipeline.Collector) error {
 			idf.deleteMetric.Add(1)
 			idf.notifyStop(id)
 			idf.deleteMapping(id)
-		} else if c.Status() != helper.ContainerStatusRunning && len(idf.LogPath) > 0 {
-			// input_file时会触发
-			idf.notifyStop(id)
+		} else if c.Status() != helper.ContainerStatusRunning && len(idf.LogPath) > 0 { // input_file时会触发
+			if idf.forceReleaseStopContainerFile {
+				idf.deleteMetric.Add(1)
+				idf.notifyStop(id)
+				idf.deleteMapping(id)
+			} else {
+				idf.notifyStop(id)
+			}
 		}
 	}
 	if allCmd != nil {