Skip to content

Commit 16950a6

Browse files
authored
[Improve][Connector-V2] Improve doris error msg (#7343)
1 parent a18fca8 commit 16950a6

File tree

1 file changed

+2
-1
lines changed
  • seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer

1 file changed

+2
-1
lines changed

seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import org.apache.seatunnel.shade.com.fasterxml.jackson.core.type.TypeReference;
2121

2222
import org.apache.seatunnel.api.table.catalog.TablePath;
23+
import org.apache.seatunnel.common.utils.ExceptionUtils;
2324
import org.apache.seatunnel.common.utils.JsonUtils;
2425
import org.apache.seatunnel.connectors.doris.config.DorisConfig;
2526
import org.apache.seatunnel.connectors.doris.exception.DorisConnectorErrorCode;
@@ -196,7 +197,7 @@ public String getLoadFailedMsg() {
196197
try {
197198
errorMessage = handlePreCommitResponse(pendingLoadFuture.get()).getMessage();
198199
} catch (Exception e) {
199-
errorMessage = e.getMessage();
200+
errorMessage = ExceptionUtils.getMessage(e);
200201
}
201202
recordStream.setErrorMessageByStreamLoad(errorMessage);
202203
return errorMessage;

0 commit comments

Comments
 (0)