Merge pull request TencentBlueKing#9 from liuwenping/master

minor: add forwarder before run
liuwenping · Sep 18, 2021 · 1dfbbba · 1dfbbba
2 parents 7e94187 + 0339188
commit 1dfbbba
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/filebeat/input/log/reader.go b/filebeat/input/log/reader.go
@@ -283,13 +283,14 @@ func (h *FileHarvester) AddForwarder(reuseReader *ReuseHarvester) error {
 		h.state.TTL = h.config.CleanInactive
 	}
 
+	//add forwarder
+	go func() {h.forwarder <- reuseReader}()
+
 	// start to read file
 	h.runOnce.Do(func() {
 		go h.Run()
 	})
 
-	//add forwarder
-	go func() {h.forwarder <- reuseReader}()
 	return nil
 }