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) {