diff --git a/hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java b/hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java index c780ded74..49db9b23a 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java @@ -21,6 +21,7 @@ package org.apache.hudi.common.config; import java.io.Serializable; import java.util.Arrays; import java.util.List; +import java.util.Objects; import java.util.Properties; import java.util.Set; import java.util.stream.Collectors; @@ -35,7 +36,11 @@ public class TypedProperties extends Properties implements Serializable { } public TypedProperties(Properties defaults) { - super(defaults); + if (Objects.nonNull(defaults)) { + for (String key : defaults.stringPropertyNames()) { + put(key, defaults.getProperty(key)); + } + } } private void checkKey(String property) { @@ -46,10 +51,7 @@ public class TypedProperties extends Properties implements Serializable { private boolean keyExists(String property) { Set keys = super.stringPropertyNames(); - if (keys.contains(property)) { - return true; - } - return false; + return keys.contains(property); } public String getString(String property) {