-
Notifications
You must be signed in to change notification settings - Fork 2.5k
[HUDI-5626] Rename CDC logging mode options #7760
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
| .stringType() | ||
| .defaultValue("cdc_data_before_after") // default record all the change log images | ||
| .defaultValue(op_key_only.name()) | ||
| .withFallbackKeys(HoodieTableConfig.CDC_SUPPLEMENTAL_LOGGING_MODE.key()) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's keep the default value of Flink as data_before_after, there are some issues maybe for the other 2 modes because Flink can trigger eager flush, the intermediate data file may cause changes loss, we can switch to other modes when I fix that.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ok got it
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@danny0405 do you have jira to track this work? i'd link it from the code as todo
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just create one: https://issues.apache.org/jira/browse/HUDI-5636
846574a to
177e797
Compare
|
rebased w/ lastest master |
Change logging mode names for CDC feature to - op_key_only - data_before - data_before_after
Change logging mode names for CDC feature to - op_key_only - data_before - data_before_after
Change Logs
Change logging mode names to
op_key_onlydata_beforedata_before_afterImpact
Config name changes. No impact as it's done before 0.13 release.
Risk level
None.
Documentation Update
NA
Contributor's checklist