-
Notifications
You must be signed in to change notification settings - Fork 2.4k
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
[HUDI-5228] Flink table service job fs view conf overwrites the one o… #7214
Conversation
* configuration {@code conf}. | ||
*/ | ||
@SuppressWarnings("rawtypes") | ||
public static HoodieFlinkWriteClient createWriteClientV2(Configuration conf) { |
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.
Can you add a parameter to determine whether to override the configuration, the name is still createWriteClient?
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.
Name it createWriteClientV2
instead of adding a param here.
…f writing job (apache#7214) (cherry picked from commit dc5cc08)
* [HUDI-5007] Prevent Hudi from reading the entire timeline's when performing a LATEST streaming read (#6920) (cherry picked from commit 6baf733) * [HUDI-5228] Flink table service job fs view conf overwrites the one of writing job (#7214) (cherry picked from commit dc5cc08) Co-authored-by: voonhous <voonhousu@gmail.com>
…f writing job
Change Logs
The table service job generates a fresh new fs view storage conf that overwrites the writing job. This could cause the writing job to failover.
Impact
No impact.
Risk level (write none, low medium or high below)
none
Documentation Update
Describe any necessary documentation update if there is any new feature, config, or user-facing change
ticket number here and follow the instruction to make
changes to the website.
Contributor's checklist