Close running outputs when reloading (#8769)

agent/agent.go

@@ -446,6 +446,13 @@ func stopServiceInputs(inputs []*models.RunningInput) {
 	}
 }
 
+// stopRunningOutputs stops all running outputs.
+func stopRunningOutputs(outputs []*models.RunningOutput) {
+	for _, output := range outputs {
+		output.Close()
+	}
+}
+
 // gather runs an input's gather function periodically until the context is
 // done.
 func (a *Agent) gatherLoop(
@@ -784,6 +791,9 @@ func (a *Agent) runOutputs(
 	cancel()
 	wg.Wait()
 
+	log.Println("I! [agent] Stopping running outputs")
+	stopRunningOutputs(unit.outputs)
+
 	return nil
 }