Skip to content

Commit 712e642

Browse files
committed
address pr comment
1 parent a939747 commit 712e642

File tree

1 file changed

+4
-2
lines changed
  • packages/aws/data_stream/cloudtrail/elasticsearch/ingest_pipeline

1 file changed

+4
-2
lines changed

‎packages/aws/data_stream/cloudtrail/elasticsearch/ingest_pipeline/default.yml‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -897,12 +897,13 @@ processors:
897897
ignore_failure: true
898898
- script:
899899
lang: painless
900+
tag: script_cache_flattened_duplicates_configuration
900901
source: |-
901902
ctx._conf = ctx._conf ?: [:];
902903
ctx._conf.keep_flattened_duplicates = ctx._conf.retain == null ||
903904
ctx._conf.retain.contains('all') ||
904905
ctx._conf.retain.contains('flattened') ||
905-
ctx._conf.retain.contains('minimal')
906+
ctx._conf.retain.contains('minimal');
906907
- script:
907908
description: >
908909
Set values in aws.cloudtrail.request_parameters, aws.cloudtrail.response_elements, and
@@ -914,6 +915,7 @@ processors:
914915
sub-fields of these field MUST NEVER be renamed or otherwise mutated, that is, they
915916
MUST NEVER be an LHS in any processor.
916917
lang: painless
918+
tag: script_duplicate_rules_fields
917919
source: |-
918920
if (ctx._conf.keep_flattened_duplicates && ctx.aws.cloudtrail?.flattened == null) {
919921
ctx.aws.cloudtrail.flattened = [:];
@@ -973,7 +975,7 @@ processors:
973975
source: >
974976
if (ctx.json?.resources instanceof List) {
975977
def resources = ctx.json.resources;
976-
978+
977979
Map uniqueResources = [:];
978980
for (def originalResource : resources) {
979981
if (originalResource instanceof Map) {

0 commit comments

Comments
 (0)