incubator-uniffle
incubator-uniffle copied to clipboard
[#1608] refactor: Reuse ShuffleManagerClient in ShuffleReader and ShuffleWriter
What changes were proposed in this pull request?
(Please outline the changes and how this PR fixes the issue.)
Why are the changes needed?
- The
createShuffleManagerClientfunction is defined in bothRssShuffleWriterandRssFetchFailedIterator. - The
ShuffleManagerClientis created inRssShuffleManagerwhenshuffleManagerRpcServiceEnabledis true. We can reuse the client inRssShuffleReaderandRssShuffleWriter.
Does this PR introduce any user-facing change?
No.
How was this patch tested?
Existing UTs.
Test Results
2 747 files + 15 2 747 suites +15 9h 48m 23s :stopwatch: + 4h 11m 44s 978 tests + 9 977 :white_check_mark: + 9 1 :zzz: ±0 0 :x: ±0 12 279 runs +135 12 264 :white_check_mark: +135 15 :zzz: ±0 0 :x: ±0
Results for commit 02ca92ce. ± Comparison against base commit 48d23ce4.
:recycle: This comment has been updated with latest results.
@zuston @advancedxy PTAL
Codecov Report
Attention: Patch coverage is 41.66667% with 49 lines in your changes missing coverage. Please review.
Project coverage is 52.62%. Comparing base (
f8e4329) to head (0bb986c). Report is 41 commits behind head on master.
Additional details and impacted files
@@ Coverage Diff @@
## master #1838 +/- ##
=============================================
+ Coverage 0 52.62% +52.62%
- Complexity 0 2561 +2561
=============================================
Files 0 415 +415
Lines 0 18784 +18784
Branches 0 1703 +1703
=============================================
+ Hits 0 9885 +9885
- Misses 0 8288 +8288
- Partials 0 611 +611
:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.
If we are trying to refactor ShuffleManagerClient, could you also consider to fix https://github.com/apache/incubator-uniffle/issues/1774 as well? @xumanbu
rssConf in ShuffleManagerGrpcClient is hard-coded.
If we are trying to refactor
ShuffleManagerClient, could you also consider to fix #1774 as well? @xumanbu
rssConfinShuffleManagerGrpcClientis hard-coded.
ok.
@xumanbu thanks for your hard work. I think it's in good shape and the right direction.
The biggest issue is how to handle close from external caller for
ExpiringCloseableSupplier.
@advancedxy Very thank you for helping me review the code and for your valuable suggestions. I'm still a bit confused by some comments, I need think about more and optimize the code.
@xumanbu thanks for your hard work. I think it's in good shape and the right direction. The biggest issue is how to handle close from external caller for
ExpiringCloseableSupplier.@advancedxy Very thank you for helping me review the code and for your valuable suggestions. I'm still a bit confused by some comments, I need think about more and optimize the code.
You are welcome. And if you have any further questions or problems, feel free to ask here.
@xumanbu other parts lgtm now. The ExpiringCloseableSupplier may still needs some refinements. Please take a look at the PR I raised in your repo.
also cc @zuston to take a look if you are interested.
Merging this since there's no objections. Others are welcome to file additional comments if any and can be addressed in a follow-up PR.
BTW, thanks your contribution @xumanbu.