-
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
Refine SegmentFetcherFactory #12936
Refine SegmentFetcherFactory #12936
Conversation
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #12936 +/- ##
============================================
+ Coverage 61.75% 62.20% +0.45%
+ Complexity 207 198 -9
============================================
Files 2436 2503 +67
Lines 133233 136463 +3230
Branches 20636 21117 +481
============================================
+ Hits 82274 84893 +2619
- Misses 44911 45296 +385
- Partials 6048 6274 +226
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
b7d20ca
to
4401fd5
Compare
Collections.shuffle(peerServerURIs); | ||
return peerServerURIs; | ||
}, destTarFile, zkMetadata.getCrypterName()); | ||
_logger.info("Downloaded tarred segment: {} from peers to: {}, file length: {}", segmentName, destTarFile, |
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.
nit: LOGGER or _logger?
it it possible to get which peer the data was downloaded from and log it out here?
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.
It should be _logger
which contains the table name info.
The actual URI picked is logged on the segment fetcher side
Separated from #12886 for easier review
SegmentFetcherFactory
a util classAPI
with URI supplier fromSegmentFetcher
intoSegmentFetcherFactory
Note: Removed
BaseTableDataManagerTest.testDownloadFromPeersWithoutStreaming()
because the test setup is incorrect (peer download scheme ishttp
but provided uri scheme isfile
). Didn't add a new test because it is just testing the mocking behavior, and the real flow is tested with integration test