From 5e9039d728221b69dc30010e73c3a0a4e7c7e7e8 Mon Sep 17 00:00:00 2001
From: kvtb <76634406+kvtb@users.noreply.github.com>
Date: Thu, 29 Sep 2022 19:20:14 +0000
Subject: client-java: handle server HTTP errors (#3762)

* client-java: handle server HTTP errors

* Update SeaweedWrite.java
---
 other/java/client/src/main/java/seaweedfs/client/SeaweedWrite.java | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'other/java/client/src')

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();
 
-- 
cgit v1.2.3