commit 501db8f1edb9b723fd0df83d06b2a50324d5be30
author wudi <676366545@qq.com> Tue May 06 11:40:56 2025 +0800
committer wudi <676366545@qq.com> Tue May 06 11:40:56 2025 +0800
tree db28c8b654be6230ce179b3962f4879530126eff
parent b40d4d73cbb7f5b5bd4d1ea728229362a0b9b9af

fix

flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
index 72c58a9..993dc65 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicOutputFormat.java
@@ -249,9 +249,8 @@
             StringJoiner value = new StringJoiner(this.fieldDelimiter);
             for (int i = 0; i < rowData.getArity() && i < fieldGetters.length; ++i) {
                 Object field = fieldGetters[i].getFieldOrNull(rowData);
-                LogicalType logicalType = logicalTypes[i];
                 // Compatible date types
-                if(LogicalTypeRoot.DATE.equals(logicalType.getTypeRoot())) {
+                if(field != null && LogicalTypeRoot.DATE.equals(logicalTypes[i].getTypeRoot())) {
                     field = Date.valueOf(LocalDate.ofEpochDay((int) field));
                 }
                 if (jsonFormat) {