diff options
| author | limd <limd@sugon.com> | 2020-08-01 01:08:30 +0800 |
|---|---|---|
| committer | limd <limd@sugon.com> | 2020-08-01 01:08:30 +0800 |
| commit | b41b7ea4d09616b42edbad87ab71ac4f2b0fa08c (patch) | |
| tree | ed398ec2e75440f48459634a1a244a9cebd167e0 /weed/s3api/s3api_object_handlers.go | |
| parent | 28764f237c5717f85c7b1fcc2846dd967a392edc (diff) | |
| download | seaweedfs-b41b7ea4d09616b42edbad87ab71ac4f2b0fa08c.tar.xz seaweedfs-b41b7ea4d09616b42edbad87ab71ac4f2b0fa08c.zip | |
fix spark read s3 bug (sc.binaryFiles)
Diffstat (limited to 'weed/s3api/s3api_object_handlers.go')
| -rw-r--r-- | weed/s3api/s3api_object_handlers.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/weed/s3api/s3api_object_handlers.go b/weed/s3api/s3api_object_handlers.go index 9773add81..357ac9ce0 100644 --- a/weed/s3api/s3api_object_handlers.go +++ b/weed/s3api/s3api_object_handlers.go @@ -230,6 +230,11 @@ func (s3a *S3ApiServer) proxyToFiler(w http.ResponseWriter, r *http.Request, des resp, postErr := client.Do(proxyReq) + if resp.ContentLength == -1 { + writeErrorResponse(w, ErrNoSuchKey, r.URL) + return + } + if postErr != nil { glog.Errorf("post to filer: %v", postErr) writeErrorResponse(w, ErrInternalError, r.URL) |