-
Notifications
You must be signed in to change notification settings - Fork 352
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
Debounce shard pruning request #5374
Conversation
89d09bd
to
b680d1e
Compare
d8a89fc
to
b08930c
Compare
db09a8e
to
cac6c90
Compare
43b202f
to
7c543ee
Compare
cac6c90
to
5ee1bd7
Compare
7c543ee
to
d1885af
Compare
5ee1bd7
to
3229965
Compare
|
||
let debouncer = self | ||
.prune_shards_debouncers | ||
.entry(( |
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.
one bummer is that this map is evergrowing.
243b1d7
to
d703a8b
Compare
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.
No real change here, just simplifying the trait bounds for readability
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.
thx
a96677b
to
4da6215
Compare
fbb8916
to
a600c3d
Compare
44290ef
to
5835f81
Compare
Description
Instead of running a separate process to clean up the shard table, we initiate the cleanup requests from the files sources. To avoid an increasing number of requests when the number of pipelines grows the requests are debounced in the control plane.
How was this PR tested?
Integration tests