lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Drop duplicate keygenerator class configuration setting (#3167)

Browse Source
This commit is contained in:
wangxianghu
2021-06-28 17:11:32 +08:00
committed by GitHub
parent d24341d10c
commit 9e61dad597
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java
View File

@@ -155,7 +155,6 @@ public class FlinkStreamerConfig extends Configuration {
conf.setBoolean(FlinkOptions.IGNORE_FAILED, config.commitOnErrors); conf.setBoolean(FlinkOptions.IGNORE_FAILED, config.commitOnErrors);
conf.setString(FlinkOptions.RECORD_KEY_FIELD, config.recordKeyField); conf.setString(FlinkOptions.RECORD_KEY_FIELD, config.recordKeyField);
conf.setString(FlinkOptions.PARTITION_PATH_FIELD, config.partitionPathField); conf.setString(FlinkOptions.PARTITION_PATH_FIELD, config.partitionPathField);
conf.setString(FlinkOptions.KEYGEN_CLASS, config.keygenClass);
if (!StringUtils.isNullOrEmpty(config.keygenClass)) { if (!StringUtils.isNullOrEmpty(config.keygenClass)) {
conf.setString(FlinkOptions.KEYGEN_CLASS, config.keygenClass); conf.setString(FlinkOptions.KEYGEN_CLASS, config.keygenClass);
} else { } else {