diff --git a/storage/go110.go b/storage/go110.go
index c1273d59ade..804d39fa936 100644
--- a/storage/go110.go
+++ b/storage/go110.go
@@ -17,6 +17,7 @@
 package storage
 
 import (
+	"io"
 	"net/url"
 	"strings"
 
@@ -24,6 +25,9 @@ import (
 )
 
 func shouldRetry(err error) bool {
+	if err == io.ErrUnexpectedEOF {
+		return true
+	}
 	switch e := err.(type) {
 	case *googleapi.Error:
 		// Retry on 429 and 5xx, according to
diff --git a/storage/go110_test.go b/storage/go110_test.go
index f1cf9bb1062..9439bb6006d 100644
--- a/storage/go110_test.go
+++ b/storage/go110_test.go
@@ -19,6 +19,7 @@ package storage
 import (
 	"context"
 	"errors"
+	"io"
 	"net/url"
 	"testing"
 
@@ -43,6 +44,7 @@ func TestInvoke(t *testing.T) {
 		{2, &googleapi.Error{Code: 518}, nil},
 		{2, &googleapi.Error{Code: 599}, &googleapi.Error{Code: 428}},
 		{1, &url.Error{Op: "blah", URL: "blah", Err: errors.New("connection refused")}, nil},
+		{1, io.ErrUnexpectedEOF, nil},
 	} {
 		counter := 0
 		call := func() error {