database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Bug][Flink] Fix when data null , flink-connector throw NullPointerException (#6165)

Browse Source
This commit is contained in:
wudi
2021-07-08 09:55:50 +08:00
committed by GitHub
parent 8a785ab08b
commit fcd31f29b6
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
View File

@ -54,6 +54,7 @@ public class DorisDynamicOutputFormat extends RichOutputFormat<RowData> {
private DorisStreamLoad dorisStreamLoad;
private final String fieldDelimiter = "\t";
private final String lineDelimiter = "\n";
private final String NULL_VALUE = "\\N";
private final List<String> batch = new ArrayList<>();
private transient volatile boolean closed = false;
@ -118,7 +119,12 @@ public class DorisDynamicOutputFormat extends RichOutputFormat<RowData> {
StringJoiner value = new StringJoiner(this.fieldDelimiter);
GenericRowData rowData = (GenericRowData) row;
for(int i = 0; i < row.getArity(); ++i) {
value.add(rowData.getField(i).toString());
Object field = rowData.getField(i);
if(field != null){
value.add(field.toString());
}else{
value.add(this.NULL_VALUE);
}
}
batch.add(value.toString());
}