handling null event time

apache · Oct 13, 2022 · b6c106d · b6c106d
1 parent e2d1dd7
commit b6c106d
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/WriteStatus.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/WriteStatus.java
@@ -25,6 +25,7 @@
 import org.apache.hudi.common.model.HoodieWriteStat;
 import org.apache.hudi.common.util.DateTimeUtils;
 import org.apache.hudi.common.util.Option;
+import org.apache.hudi.common.util.StringUtils;
 
 import org.apache.log4j.LogManager;
 import org.apache.log4j.Logger;
@@ -99,9 +100,11 @@ public void markSuccess(HoodieRecord record, Option<Map<String, String>> optiona
     if (optionalRecordMetadata.isPresent()) {
       String eventTimeVal = optionalRecordMetadata.get().getOrDefault(METADATA_EVENT_TIME_KEY, null);
       try {
-        long eventTime = DateTimeUtils.parseDateTime(eventTimeVal).toEpochMilli();
-        stat.setMinEventTime(eventTime);
-        stat.setMaxEventTime(eventTime);
+        if (!StringUtils.isNullOrEmpty(eventTimeVal)) {
+          long eventTime = DateTimeUtils.parseDateTime(eventTimeVal).toEpochMilli();
+          stat.setMinEventTime(eventTime);
+          stat.setMaxEventTime(eventTime);
+        }
       } catch (DateTimeException | IllegalArgumentException e) {
         LOG.debug(String.format("Fail to parse event time value: %s", eventTimeVal), e);
       }