diff --git a/app/file.go b/app/file.go
index a47e817003..7a66d25010 100644
--- a/app/file.go
+++ b/app/file.go
@@ -824,6 +824,7 @@ func (t *UploadFileTask) postprocessImage(file io.Reader) {
 		_, aerr := t.writeFile(r, path)
 		if aerr != nil {
 			mlog.Error("Unable to upload", mlog.String("path", path), mlog.Err(aerr))
+			r.CloseWithError(aerr) // always returns nil
 			return
 		}
 	}
diff --git a/app/upload.go b/app/upload.go
index ef4bff2b71..318e3ede89 100644
--- a/app/upload.go
+++ b/app/upload.go
@@ -93,6 +93,7 @@ func (a *App) runPluginsHook(c request.CTX, info *model.FileInfo, file io.Reader
 		if fileErr := a.RemoveFile(tmpPath); fileErr != nil {
 			mlog.Warn("Failed to remove file", mlog.Err(fileErr))
 		}
+		r.CloseWithError(err) // always returns nil
 		return err
 	}