diff --git a/v2/pkg/operators/operators.go b/v2/pkg/operators/operators.go index 4cc4e6f99..5ba2a7548 100644 --- a/v2/pkg/operators/operators.go +++ b/v2/pkg/operators/operators.go @@ -167,12 +167,6 @@ func (r *Result) Merge(result *Result) { r.OutputExtracts = append(r.OutputExtracts, v) } } - for _, v := range result.OutputExtracts { - if _, ok := r.outputUnique[v]; !ok { - r.outputUnique[v] = struct{}{} - r.OutputExtracts = append(r.OutputExtracts, v) - } - } for k, v := range result.DynamicValues { r.DynamicValues[k] = v } diff --git a/v2/pkg/protocols/file/request.go b/v2/pkg/protocols/file/request.go index 20feece3a..cbc655dbe 100644 --- a/v2/pkg/protocols/file/request.go +++ b/v2/pkg/protocols/file/request.go @@ -159,7 +159,7 @@ func (request *Request) processFile(filePath, input string, previousInternalEven func (request *Request) processReader(reader io.Reader, filePath, input, totalBytesString string, previousInternalEvent output.InternalEvent) (*output.InternalWrappedEvent, []FileMatch, error) { fileReader := io.LimitReader(reader, request.maxSize) fileMatches, opResult := request.findMatchesWithReader(fileReader, input, filePath, totalBytesString, previousInternalEvent) - if len(fileMatches) == 0 || opResult == nil { + if opResult == nil && len(fileMatches) == 0 { return nil, nil, emptyResultErr }