diff --git a/pkg/provider/ffmpeg/stubber.go b/pkg/provider/ffmpeg/stubber.go
index 1f70deb..6ec019a 100644
--- a/pkg/provider/ffmpeg/stubber.go
+++ b/pkg/provider/ffmpeg/stubber.go
@@ -98,16 +98,25 @@ func (l *Stubber) Run(ctx context.Context, target string, args, envs []string) e
 	// Copy cmd stdout to ssh session
 	go func() {
 		_, _ = io.Copy(l.Session, stdOut)
+		logrus.Infof("Copy cmd stdout to ssh session's stdout finished")
+		_ = stdOut.Close()
 	}()
 
 	// Copy cmd stderr to ssh session's stderr
 	go func() {
 		_, _ = io.Copy(l.Session.Stderr(), stdErr)
+		logrus.Infof("Copy cmd stderr to ssh session's stderr finished")
+		_ = stdErr.Close()
 	}()
 
 	// Copy stdin from session to cmd stdin
 	go func() {
-		_, _ = io.Copy(stdIn, l.Session)
+		_, err := io.Copy(stdIn, l.Session)
+		if err != nil {
+			logrus.Errorf("io.Copy(stdIn, l.Session) error: %v", err)
+		}
+		logrus.Infof("Copy stdin from session to cmd stdin finished")
+		_ = stdIn.Close()
 	}()
 
 	if err = cmd.Wait(); err != nil {