[Autodiscover] Check if runner is already running before starting again

CHANGELOG.next.asciidoc

@@ -86,6 +86,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
 - Fix panic when assigning a key to a `nil` value in an event. {pull}18143[18143]
 - Gives monitoring reporter hosts, if configured, total precedence over corresponding output hosts. {issue}17937[17937] {pull}17991[17991]
 - Change `decode_json_fields` processor, to merge parsed json objects with existing objects in the event instead of fully replacing them. {pull}17958[17958]
+- [Autodiscover] Check if runner is already running before starting again. {pull}18564[18564]
 
 *Auditbeat*
 

libbeat/cfgfile/list.go

@@ -73,7 +73,11 @@ func (r *RunnerList) Reload(configs []*reload.ConfigWithMeta) error {
 		if _, ok := stopList[hash]; ok {
 			delete(stopList, hash)
 		} else {
-			startList[hash] = config
+			if _, ok := r.runners[hash]; !ok {
+				startList[hash] = config
+			} else {
+				r.logger.Debugf("Runner already running for this config hash: %s", hash)
+			}
 		}
 	}
 

libbeat/cfgfile/list_test.go

@@ -103,6 +103,27 @@ func TestReloadSameConfigs(t *testing.T) {
 	assert.Equal(t, state, list.copyRunnerList())
 }
 
+func TestReloadDuplicateConfig(t *testing.T) {
+	factory := &runnerFactory{}
+	list := NewRunnerList("", factory, nil)
+
+	list.Reload([]*reload.ConfigWithMeta{
+		createConfig(1),
+	})
+
+	state := list.copyRunnerList()
+	assert.Equal(t, len(state), 1)
+
+	// This can happen in Autodiscover when a container if getting restarted but the previous one is not clean yet.
+	list.Reload([]*reload.ConfigWithMeta{
+		createConfig(1),
+		createConfig(1),
+	})
+
+	// nothing changed
+	assert.Equal(t, state, list.copyRunnerList())
+}
+
 func TestReloadStopConfigs(t *testing.T) {
 	factory := &runnerFactory{}
 	list := NewRunnerList("", factory, nil)