-
Notifications
You must be signed in to change notification settings - Fork 49
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
[Bifrost] Allow top-level find_tail to auto-retry #2649
Conversation
91b9130
to
bc16992
Compare
Test Results 7 files ±0 7 suites ±0 2m 43s ⏱️ -52s Results for commit bc16992. ± Comparison against base commit d730f92. This pull request removes 2 and adds 2 tests. Note that renamed tests count towards both.
|
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.
LGTM. +1 for merging.
crates/bifrost/src/error.rs
Outdated
// #[error("log '{0}' is sealed")] | ||
// LogSealed(LogId), |
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 this be removed?
Previously, setting target nodeset size with restatectl would tell you that "No change" ``` // intentionally empty ```
The PR also uses it in CheckSeal. This utility `DecoratedNodeSet` can be used when you want to add a nugget of information next to every node. It prints the nodeset sorted as well. ``` // intentionally empty ```
Key changes: - Using JoinSet instead of unordered futures to perform store tasks to avoid some of its tricky lockup scenarios - Store tasks are free to use whatever connection is available, this over-indexes over the current design that serializes all writes in a one-at-a-time fashion, but removes a lock, and simplifies the logic. - Extra in-flight stores are aborted after an append is complete to avoid overloading - Timeout store tasks only on the basis of their network operation and not on the time they're waiting for the tail to move - Cache nodeset checker across waves - Better logging on failures, it reports the nodeset status with the number of attempts per node - Adds a new metric to latency of appends Performance testing shows no regression and reliability testing appears to show no regression even in tricky failure scenarios. ``` // intentionally empty ```
Those find_tail operations are only used by the partition_processor on startup and we don't want it to fail unnecessarily, this gives it a good chance to succeed unless the underlying error is not retryable. ``` // intentionally empty ```
Those find_tail operations are only used by the partition_processor on startup and we don't want it to fail unnecessarily, this gives it a good chance to succeed unless the underlying error is not retryable.
Stack created with Sapling. Best reviewed with ReviewStack.
DecoratedNodeSet
Utility to display decorated nodesets #2646