diff --git a/pkg/client/live/client.go b/pkg/client/live/client.go
index a043d95e..95ac91cf 100644
--- a/pkg/client/live/client.go
+++ b/pkg/client/live/client.go
@@ -262,7 +262,11 @@ func (c *Client) Stream(r io.Reader) error {
 			return nil
 		default:
 			bytesRead, err := r.Read(chunk)
-			if err != nil {
+			if err == io.EOF && !c.retry {
+				klog.V(3).Infof("stream object EOF\n")
+				klog.V(6).Infof("live.Stream() LEAVE\n")
+				return nil
+			} else if err != nil {
 				klog.V(4).Infof("r.Read encountered EOF. Err: %v\n", err)
 				klog.V(6).Infof("live.Stream() LEAVE\n")
 				return err