Handle missing key case gracefully

elastic · May 13, 2020 · 0a7e6b5 · 0a7e6b5
1 parent 5c02b87
commit 0a7e6b5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/libbeat/outputs/elasticsearch/client.go b/libbeat/outputs/elasticsearch/client.go
@@ -346,6 +346,9 @@ func createEventBulkMeta(
 func getPipeline(event *beat.Event, pipelineSel *outil.Selector) (string, error) {
 	if event.Meta != nil {
 		pipeline, err := events.GetMetaStringValue(*event, events.FieldMetaPipeline)
+		if err == common.ErrKeyNotFound {
+			return "", nil
+		}
 		if err != nil {
 			return "", errors.New("pipeline metadata is no string")
 		}