diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/Option.java b/hudi-common/src/main/java/org/apache/hudi/common/util/Option.java index a67b6ab95..42d605796 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/Option.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/Option.java @@ -98,6 +98,9 @@ public final class Option implements Serializable { } public Option map(Function mapper) { + if (null == mapper) { + throw new NullPointerException("mapper should not be null"); + } if (!isPresent()) { return empty(); } else { @@ -140,6 +143,8 @@ public final class Option implements Serializable { @Override public String toString() { - return "Option{val=" + val + '}'; + return val != null + ? "Option{val=" + val + "}" + : "Optional.empty"; } }