chore(fix): batch csv missing nl

Signed-off-by: Jiyong Huang <huangjy@emqx.io>
ngjaying · Dec 25, 2024 · 3ea9dc1 · 3ea9dc1
1 parent 825cdff
commit 3ea9dc1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/topo/node/batch_op.go b/internal/topo/node/batch_op.go
@@ -130,7 +130,7 @@ func (b *BatchOp) ingest(ctx api.StreamContext, item any, checkSize bool) {
 		if b.hasHeader && b.rawHeader == nil {
 			newlineIndex := bytes.IndexByte(input.Raw(), '\n')
 			if newlineIndex != -1 {
-				b.rawHeader = input.Raw()[:newlineIndex]
+				b.rawHeader = input.Raw()[:newlineIndex+1]
 				ctx.GetLogger().Infof("Get new header")
 			} else {
 				ctx.GetLogger().Infof("No header found")