-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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
handle absent segments so that catchup checker doesn't get stuck on them #12883
handle absent segments so that catchup checker doesn't get stuck on them #12883
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #12883 +/- ##
============================================
+ Coverage 61.75% 62.13% +0.38%
+ Complexity 207 198 -9
============================================
Files 2436 2502 +66
Lines 133233 136547 +3314
Branches 20636 21137 +501
============================================
+ Hits 82274 84840 +2566
- Misses 44911 45423 +512
- Partials 6048 6284 +236
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
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.
I don't like the extra timeout introduced here because it is not robust.
One solution could be: when we cannot find the table/segment served on the server, read the ideal state again to read the source of truth, then decide whether to skip it
Fix #12381 |
b681ee1
to
7b5fa51
Compare
7b5fa51
to
f1a9673
Compare
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
Outdated
Show resolved
Hide resolved
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/FreshnessBasedConsumptionStatusChecker.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/IngestionBasedConsumptionStatusChecker.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/IngestionBasedConsumptionStatusChecker.java
Show resolved
Hide resolved
e9065d4
to
e85130c
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.
LGTM
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/BaseServerStarter.java
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/IngestionBasedConsumptionStatusChecker.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/IngestionBasedConsumptionStatusChecker.java
Outdated
Show resolved
Hide resolved
.../main/java/org/apache/pinot/server/starter/helix/IngestionBasedConsumptionStatusChecker.java
Show resolved
Hide resolved
…mmitted by other servers
Handle absent segments so that catchup checker doesn't get stuck on them. When server is catching up, the tables or segments might get dropped, if those segments are not skipped, the checker will block server from starting up.