This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new d794f4fbf9 [MINOR] Optimize code logic (#5499)
d794f4fbf9 is described below
commit d794f4fbf9d8ce4c90507e4de36121ac1fc2fd4b
Author: qianchutao <[email protected]>
AuthorDate: Fri May 6 00:33:06 2022 +0800
[MINOR] Optimize code logic (#5499)
---
.../org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
index 56124b82af..824c7375fa 100644
---
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
+++
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java
@@ -625,8 +625,8 @@ public class HoodieDeltaStreamer implements Serializable {
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 "
+ cfg.baseFileFormat);
- cfg.baseFileFormat =
meta.getTableConfig().getBaseFileFormat().toString();
- this.cfg.baseFileFormat = cfg.baseFileFormat;
+ cfg.baseFileFormat = baseFileFormat;
+ this.cfg.baseFileFormat = baseFileFormat;
} else {
tableType = HoodieTableType.valueOf(cfg.tableType);
if (cfg.baseFileFormat == null) {
