Skip to content

Commit 0fab2e9

Browse files
committed
Fix bug with empty files in S3
1 parent 2836509 commit 0fab2e9

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

storage/s3/s3.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,9 @@ func (st *S3Storage) PutObject(obj *storage.Object) error {
162162
} else if (err != nil) && (i < st.retryCnt) {
163163
storage.Log.Debugf("S3 obj uploading failed with error: %s", err)
164164
time.Sleep(st.retryInterval)
165+
if _, err := rlReader.Seek(0,0); err != nil {
166+
return err
167+
}
165168
continue
166169
} else if (err != nil) && (i == st.retryCnt) {
167170
return err

0 commit comments

Comments
 (0)