Skip to content

Commit

Permalink
Addressed comments
Browse files Browse the repository at this point in the history
  • Loading branch information
avilevy18 committed Oct 30, 2023
1 parent 37fd576 commit 9207222
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
2 changes: 1 addition & 1 deletion transformation_test/testdata/modify_fields/config.yaml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
- type: modify_fields
fields:
jsonPayload.hello:
static_value: world
static_value: world
8 changes: 5 additions & 3 deletions transformation_test/transformation_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,6 @@ import (
"os/exec"
"path/filepath"
"strconv"
"strings"
"testing"
"time"

Expand Down Expand Up @@ -85,8 +84,11 @@ func TestTransformationTests(t *testing.T) {
}

// Start Fluent-bit
arg := fmt.Sprintf("--config=%s --parser=%s -v", filepath.Join(tempPath, flbMainConf), filepath.Join(filepath.Join(tempPath, flbParserConf)))
cmd := exec.Command(fmt.Sprintf("%s/fluent-bit", *flbPath), strings.Split(arg, " ")...)
cmd := exec.Command(
fmt.Sprintf("%s/fluent-bit", *flbPath),
"-v",
fmt.Sprintf("--config=%s", filepath.Join(tempPath, flbMainConf)),
fmt.Sprintf("--parser=%s", filepath.Join(filepath.Join(tempPath, flbParserConf))))

var stdout, stderr io.ReadCloser
stdout, err = cmd.StdoutPipe()
Expand Down

0 comments on commit 9207222

Please sign in to comment.