diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
index 060bccb5f..884598973 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
@@ -339,7 +339,15 @@ public void startLoad(String label, boolean isResume) throws IOException {
                     executorService.submit(
                             () -> {
                                 LOG.info(executeMessage);
-                                return httpClient.execute(putBuilder.build());
+                                try {
+                                    return httpClient.execute(putBuilder.build());
+                                } catch (Exception e) {
+                                    String errMsg =
+                                            String.format(
+                                                    "Failed to execute load data; url: %s",
+                                                    loadUrlStr);
+                                    throw new DorisException(errMsg, e);
+                                }
                             });
         } catch (Exception e) {
             String err;