Skip to content

Commit a02eef9

Browse files
dujieyanghuaiGit
authored andcommitted
[hotfix-884][doris][ftp]print dirty data when dirty type is log for doris & ftp plugin
(cherry picked from commit 1dba62d)
1 parent 3c66d07 commit a02eef9

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

chunjun-connectors/chunjun-connector-doris/src/main/java/com/dtstack/chunjun/connector/doris/sink/DorisHttpOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ protected void writeSingleRecordInternal(RowData rowData) throws WriteRecordExce
8888
try {
8989
client.process(rowData, columns, rowConverter);
9090
} catch (Exception e) {
91-
throw new WriteRecordException("", e);
91+
throw new WriteRecordException("", e, 0, rowData);
9292
}
9393
}
9494

chunjun-connectors/chunjun-connector-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/sink/FtpOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ public void writeSingleRecordToFile(RowData rowData) throws WriteRecordException
122122
rowsOfCurrentBlock++;
123123
lastRow = rowData;
124124
} catch (Exception ex) {
125-
throw new WriteRecordException(ex.getMessage(), ex);
125+
throw new WriteRecordException(ex.getMessage(), ex, 0, rowData);
126126
}
127127
}
128128

0 commit comments

Comments
 (0)