Merge pull request #236 from OlivierCazade/fix-ingest-compilation

OlivierCazade · web-flow · commit 24bcbf2b9371 · 2022-06-17T11:23:46.000+02:00
Fix ingest compilation
diff --git a/pkg/pipeline/ingest/ingest_collector.go b/pkg/pipeline/ingest/ingest_collector.go
@@ -183,8 +183,7 @@ func (ingestC *ingestCollector) processLogLines(out chan<- []config.GenericMap)
 				if len(ingestC.in) > 0 {
 					for len(records) < ingestC.batchMaxLength && len(ingestC.in) > 0 {
 						record := <-ingestC.in
-						recordAsBytes, _ := json.Marshal(record)
-						records = append(records, string(recordAsBytes))
+						records = append(records, record)
 					}
 				}
 				log.Debugf("ingestCollector sending %d entries, %d entries waiting", len(records), len(ingestC.in))

Original file line number	Diff line number	Diff line change
`@@ -183,8 +183,7 @@ func (ingestC *ingestCollector) processLogLines(out chan<- []config.GenericMap)`
`183`	`183`	`if len(ingestC.in) > 0 {`
`184`	`184`	`for len(records) < ingestC.batchMaxLength && len(ingestC.in) > 0 {`
`185`	`185`	`record := <-ingestC.in`
`186`		`- recordAsBytes, _ := json.Marshal(record)`
`187`		`- records = append(records, string(recordAsBytes))`
	`186`	`+ records = append(records, record)`
`188`	`187`	`}`
`189`	`188`	`}`
`190`	`189`	`log.Debugf("ingestCollector sending %d entries, %d entries waiting", len(records), len(ingestC.in))`