From fdc717506eb58ceec290d27ab79019fdac1beb10 Mon Sep 17 00:00:00 2001
From: Zhenyu Luo <luoluoyuyu2001@gmail.com>
Date: Tue, 29 Oct 2024 21:42:10 +0800
Subject: [PATCH] Pipe: Fix TsFileInsertionEventTableParserTabletIterator NPE
 issue (#13955)

---
 .../table/TsFileInsertionEventTableParserTabletIterator.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParserTabletIterator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParserTabletIterator.java
index c33cb7427275..fb11bbc8e275 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParserTabletIterator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/table/TsFileInsertionEventTableParserTabletIterator.java
@@ -120,7 +120,7 @@ private Tablet buildNextTablet() throws IOException {
       tablet.addTimestamp(rowIndex, timestamp);
       for (int i = 0, fieldSize = row.length - 1; i < fieldSize; i++) {
         final Object value =
-            columnSchemas.get(i).getType() != DATE
+            columnSchemas.get(i).getType() != DATE || row[i] == null
                 ? row[i]
                 : DateUtils.parseIntToLocalDate((Integer) row[i]);
         tablet.addValue(columnNames.get(i), rowIndex, value);