lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1943] Lose properties when hoodieWriteConfig initializtion (#3006)

Browse Source 
* [hudi-flink]fix lose properties problem

Co-authored-by: haoke <haoke@bytedance.com>
This commit is contained in:
hk__lrzy
2021-06-01 16:09:48 +08:00
committed by GitHub
parent e6a71ea544
commit 83b0301c1a
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java
View File

@@ -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<String> keys = super.stringPropertyNames();
if (keys.contains(property)) {
return true;
}
return false;
return keys.contains(property);
}
public String getString(String property) {