diff options
| author | kvtb <76634406+kvtb@users.noreply.github.com> | 2022-09-29 19:20:14 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-09-29 12:20:14 -0700 |
| commit | 5e9039d728221b69dc30010e73c3a0a4e7c7e7e8 (patch) | |
| tree | 5957b04cd97ec6a5cc1daa4f3297ac25e10592d4 /other/java/client/src | |
| parent | e00a12b099213515b49fbdb97544b9e5ee734e90 (diff) | |
| download | seaweedfs-5e9039d728221b69dc30010e73c3a0a4e7c7e7e8.tar.xz seaweedfs-5e9039d728221b69dc30010e73c3a0a4e7c7e7e8.zip | |
client-java: handle server HTTP errors (#3762)
* client-java: handle server HTTP errors
* Update SeaweedWrite.java
Diffstat (limited to 'other/java/client/src')
| -rw-r--r-- | other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java index 1ee745ed0..df45dd3f2 100644 --- a/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java +++ b/other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java @@ -149,6 +149,13 @@ public class SeaweedWrite { CloseableHttpResponse response = SeaweedUtil.getClosableHttpClient().execute(post); try { + if (response.getStatusLine().getStatusCode() / 100 != 2) { + if (response.getEntity().getContentType() != null && response.getEntity().getContentType().getValue().equals("application/json")) { + throw new IOException(EntityUtils.toString(response.getEntity(), "UTF-8")); + } else { + throw new IOException(response.getStatusLine().getReasonPhrase()); + } + } String etag = response.getLastHeader("ETag").getValue(); |