diff --git a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/sink/DorisHttpOutputFormat.java b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/sink/DorisHttpOutputFormat.java index e79bf3a81b..3580f6be7d 100644 --- a/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/sink/DorisHttpOutputFormat.java +++ b/chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/sink/DorisHttpOutputFormat.java @@ -88,7 +88,7 @@ protected void writeSingleRecordInternal(RowData rowData) throws WriteRecordExce try { client.process(rowData, columns, rowConverter); } catch (Exception e) { - throw new WriteRecordException("", e); + throw new WriteRecordException("", e, 0, rowData); } } diff --git a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java index 5b3134c4cd..4d3ad15521 100644 --- a/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java +++ b/chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java @@ -122,7 +122,7 @@ public void writeSingleRecordToFile(RowData rowData) throws WriteRecordException rowsOfCurrentBlock++; lastRow = rowData; } catch (Exception ex) { - throw new WriteRecordException(ex.getMessage(), ex); + throw new WriteRecordException(ex.getMessage(), ex, 0, rowData); } }