-
Notifications
You must be signed in to change notification settings - Fork 590
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
feat: support background DDL for MV on shared source #18919
feat: support background DDL for MV on shared source #18919
Conversation
This stack of pull requests is managed by Graphite. Learn more about stacking. |
1ba3525
to
16e430d
Compare
651dd45
to
3bb6e7b
Compare
16e430d
to
5282fa9
Compare
3bb6e7b
to
4b11a81
Compare
5282fa9
to
6ed05a4
Compare
4b11a81
to
ec97955
Compare
6ed05a4
to
14e84ce
Compare
ec97955
to
13e0d77
Compare
13e0d77
to
30c3895
Compare
kindly ping reviewers here |
Will have a look by today |
/// Some other leaf nodes like `StreamValues` do not support recovery, and they | ||
/// cannot use background ddl. |
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.
Do we have an issue for this? Is it possible to address this by simply recording the state into a state table?
Co-authored-by: xxchan <[email protected]>
pub(crate) fn plan_has_backfill_leaf_nodes(plan: &PlanRef) -> bool { | ||
/// Some other leaf nodes like `StreamValues` do not support recovery, and they | ||
/// cannot use background ddl. | ||
pub(crate) fn plan_can_use_backgronud_ddl(plan: &PlanRef) -> bool { |
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.
typo background
if plan.inputs().is_empty() { | ||
if let Some(scan) = plan.as_stream_table_scan() { | ||
if plan.as_stream_source_scan().is_some() { |
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.
For stream_source_scan
it is only used by source backfill right? If so this LGTM.
I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.
What's changed and what's your intention?
follow up of #18112, where we only implemented the track mechanism in meta, but it's banned in frontend
#18338
Checklist
./risedev check
(or alias,./risedev c
)Documentation
Release note
If this PR includes changes that directly affect users or other significant modifications relevant to the community, kindly draft a release note to provide a concise summary of these changes. Please prioritize highlighting the impact these changes will have on users.