add wg to startPoller to ensure globTicker.Stop() is called during sh…

…utdown
observIQ · Aug 17, 2021 · 9ce72a1 · 9ce72a1
1 parent 5cd08a9
commit 9ce72a1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/operator/builtin/input/journald/journald.go b/operator/builtin/input/journald/journald.go
@@ -138,6 +138,9 @@ func (operator *JournaldInput) Start() error {
 func (operator *JournaldInput) startPoller(ctx context.Context) {
 	go func() {
 		globTicker := time.NewTicker(operator.pollInterval)
+		operator.wg.Add(1)
+
+		defer operator.wg.Done()
 		defer globTicker.Stop()
 
 		for {