From 904bd936d06444f4485c8823b6bcf03401269a2e Mon Sep 17 00:00:00 2001
From: liuwenping <haha.rober@gmail.com>
Date: Sat, 18 Sep 2021 17:38:15 +0800
Subject: [PATCH] minor: add forwarder before run

---
 filebeat/input/log/reader.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/filebeat/input/log/reader.go b/filebeat/input/log/reader.go
index b3ed2dbe406c..8695e41ccd41 100644
--- 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
 }