[BuxFix] [Kafka-Connector] Fixed null pointer issue when kafka uses j…

…son to read datetime type encountering null values
LeonYoah · Jul 10, 2024 · 0a8e618 · 0a8e618
1 parent 57e5627
commit 0a8e618
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...unnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java b/...unnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java
@@ -250,6 +250,9 @@ private float convertToFloat(JsonNode jsonNode) {
     }
 
     private LocalDate convertToLocalDate(JsonNode jsonNode, String fieldName) {
+        if ("".equals(jsonNode.asText())) {
+            return null;
+        }
         String dateStr = jsonNode.asText();
         DateTimeFormatter dateFormatter = fieldFormatterMap.get(fieldName);
         if (dateFormatter == null) {
@@ -261,11 +264,17 @@ private LocalDate convertToLocalDate(JsonNode jsonNode, String fieldName) {
     }
 
     private LocalTime convertToLocalTime(JsonNode jsonNode) {
+        if ("".equals(jsonNode.asText())) {
+            return null;
+        }
         TemporalAccessor parsedTime = TIME_FORMAT.parse(jsonNode.asText());
         return parsedTime.query(TemporalQueries.localTime());
     }
 
     private LocalDateTime convertToLocalDateTime(JsonNode jsonNode, String fieldName) {
+        if ("".equals(jsonNode.asText())) {
+            return null;
+        }
         String datetimeStr = jsonNode.asText();
         DateTimeFormatter dateTimeFormatter = fieldFormatterMap.get(fieldName);
         if (dateTimeFormatter == null) {