diff --git a/extractors/plugin_load.go b/extractors/plugin_load.go
index 2e6c769..1ecbe7e 100644
--- a/extractors/plugin_load.go
+++ b/extractors/plugin_load.go
@@ -3,6 +3,7 @@ package extractors
 import (
 	"bufio"
 	"encoding/json"
+	"io"
 	"log"
 	"os"
 	"os/exec"
@@ -52,7 +53,7 @@ func (ml *PluginLoadStep) Start(task task.RuntimeTask) (chan map[string]interfac
 
 			for err == nil {
 				line, isPrefix, err = reader.ReadLine()
-				if err != nil {
+				if err != nil && err != io.EOF {
 					log.Printf("plugin (%s) input error: %s", ml.CommandLine, err)
 				}
 				ln = append(ln, line...)
diff --git a/transform/plugin.go b/transform/plugin.go
index 287541a..cfe3b18 100644
--- a/transform/plugin.go
+++ b/transform/plugin.go
@@ -3,6 +3,7 @@ package transform
 import (
 	"bufio"
 	"encoding/json"
+	"io"
 	"log"
 	"os"
 	"os/exec"
@@ -61,7 +62,7 @@ func (ps *pluginProcess) Process(in chan map[string]any, out chan map[string]any
 
 			for err == nil {
 				line, isPrefix, err = reader.ReadLine()
-				if err != nil {
+				if err != nil && err != io.EOF {
 					log.Printf("plugin (%s) input error: %s", ps.config.CommandLine, err)
 				}
 				ln = append(ln, line...)