-
Notifications
You must be signed in to change notification settings - Fork 594
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(snapshot-backfill): introduce state to snapshot backfill #19720
base: yiming/snapshot-backfill-vnode-stream
Are you sure you want to change the base?
feat(snapshot-backfill): introduce state to snapshot backfill #19720
Conversation
Warning This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
This stack of pull requests is managed by Graphite. Learn more about stacking. |
641fa65
to
a3f0881
Compare
c2868dd
to
d5c4a10
Compare
5567d22
to
ba717b7
Compare
if self.streams.is_empty() { | ||
break Poll::Ready(Ok(None)); | ||
} | ||
for (vnode, stream) in &mut self.streams { |
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.
Will polling the streams in vnode order cause starvation or data skew in downstream? Should we use FuturesUnordered
instead?
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.
Changed to use FuturesUnordered
in #19936
ba717b7
to
353a5c9
Compare
353a5c9
to
45a1be4
Compare
45a1be4
to
0fb452c
Compare
2d2947f
to
579b264
Compare
0fb452c
to
7a48e72
Compare
I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.
What's changed and what's your intention?
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.