[Improve][Connector-V2] Improve doris error msg (#7343)

apache · Aug 8, 2024 · 16950a6 · 16950a6
1 parent a18fca8
commit 16950a6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...oris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java b/...oris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java
@@ -20,6 +20,7 @@
 import org.apache.seatunnel.shade.com.fasterxml.jackson.core.type.TypeReference;
 
 import org.apache.seatunnel.api.table.catalog.TablePath;
+import org.apache.seatunnel.common.utils.ExceptionUtils;
 import org.apache.seatunnel.common.utils.JsonUtils;
 import org.apache.seatunnel.connectors.doris.config.DorisConfig;
 import org.apache.seatunnel.connectors.doris.exception.DorisConnectorErrorCode;
@@ -196,7 +197,7 @@ public String getLoadFailedMsg() {
             try {
                 errorMessage = handlePreCommitResponse(pendingLoadFuture.get()).getMessage();
             } catch (Exception e) {
-                errorMessage = e.getMessage();
+                errorMessage = ExceptionUtils.getMessage(e);
             }
             recordStream.setErrorMessageByStreamLoad(errorMessage);
             return errorMessage;