We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b40d4d7 commit 501db8fCopy full SHA for 501db8f
1 file changed
flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
@@ -249,9 +249,8 @@ private void addBatch(T row) {
249
StringJoiner value = new StringJoiner(this.fieldDelimiter);
250
for (int i = 0; i < rowData.getArity() && i < fieldGetters.length; ++i) {
251
Object field = fieldGetters[i].getFieldOrNull(rowData);
252
- LogicalType logicalType = logicalTypes[i];
253
// Compatible date types
254
- if(LogicalTypeRoot.DATE.equals(logicalType.getTypeRoot())) {
+ if(field != null && LogicalTypeRoot.DATE.equals(logicalTypes[i].getTypeRoot())) {
255
field = Date.valueOf(LocalDate.ofEpochDay((int) field));
256
}
257
if (jsonFormat) {
0 commit comments