diff options
| -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(); |