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
createShuffleManagerClient
function is defined in bothRssShuffleWriter
andRssFetchFailedIterator
. - The
ShuffleManagerClient
is created inRssShuffleManager
whenshuffleManagerRpcServiceEnabled
is true. We can reuse the client inRssShuffleReader
andRssShuffleWriter
.
Does this PR introduce any user-facing change?
No.
How was this patch tested?
Existing UTs.