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 index 8f74858669278..b306d6c540017 100644 --- 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> 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); }