lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Optimize code logic (#5499)

Browse Source
This commit is contained in:
qianchutao
2022-05-06 00:33:06 +08:00
committed by GitHub
parent f66e83dc65
commit d794f4fbf9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
View File

@@ -625,8 +625,8 @@ public class HoodieDeltaStreamer implements Serializable {
ValidationUtils.checkArgument(baseFileFormat.equals(cfg.baseFileFormat) || cfg.baseFileFormat == null, ValidationUtils.checkArgument(baseFileFormat.equals(cfg.baseFileFormat) || cfg.baseFileFormat == null,
"Hoodie table's base file format is of type " + baseFileFormat + " but passed in CLI argument is " "Hoodie table's base file format is of type " + baseFileFormat + " but passed in CLI argument is "
+ cfg.baseFileFormat); + cfg.baseFileFormat);
cfg.baseFileFormat = meta.getTableConfig().getBaseFileFormat().toString(); cfg.baseFileFormat = baseFileFormat;
this.cfg.baseFileFormat = cfg.baseFileFormat; this.cfg.baseFileFormat = baseFileFormat;
} else { } else {
tableType = HoodieTableType.valueOf(cfg.tableType); tableType = HoodieTableType.valueOf(cfg.tableType);
if (cfg.baseFileFormat == null) { if (cfg.baseFileFormat == null) {