This is an automated email from the ASF dual-hosted git repository.
zuston pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/uniffle.git
from 293d01b24 [#1745][FOLLOWUP] fix(client): exclude kryo when package
spark shaded client (#2478)
add cc440dfe0 [#2469] feat(spark): Introducing a dedicated shuffleId of
uniffle for stage retry (#2471)
No new revisions were added by this update.
Summary of changes:
.../hadoop/mapreduce/v2/app/RssMRAppMaster.java | 1 -
.../hadoop/mapred/SortWriteBufferManagerTest.java | 4 -
.../hadoop/mapreduce/task/reduce/FetcherTest.java | 4 -
.../uniffle/shuffle/ShuffleIdMappingManager.java | 128 +++++++++++++++++++++
.../shuffle/manager/RssShuffleManagerBase.java | 93 ++-------------
.../apache/spark/shuffle/RssShuffleManager.java | 20 ++--
.../apache/spark/shuffle/RssShuffleManager.java | 28 +++--
.../tez/dag/app/TezRemoteShuffleManager.java | 1 -
.../common/sort/buffer/WriteBufferManagerTest.java | 4 -
.../uniffle/client/api/ShuffleWriteClient.java | 11 --
.../client/impl/ShuffleWriteClientImpl.java | 8 --
.../record/reader/MockedShuffleWriteClient.java | 4 -
.../coordinator/CoordinatorGrpcService.java | 14 +--
.../test/RemoteMergeShuffleWithRssClientTest.java | 4 -
...ShuffleWithRssClientTestWhenShuffleFlushed.java | 4 -
.../client/impl/grpc/CoordinatorGrpcClient.java | 13 +--
.../client/impl/grpc/ShuffleServerGrpcClient.java | 3 -
.../request/RssGetShuffleAssignmentsRequest.java | 24 ----
.../client/request/RssRegisterShuffleRequest.java | 11 --
proto/src/main/proto/Rss.proto | 8 +-
.../uniffle/server/ShuffleServerGrpcService.java | 102 ++--------------
.../apache/uniffle/server/ShuffleTaskManager.java | 3 -
22 files changed, 183 insertions(+), 309 deletions(-)
create mode 100644
client-spark/common/src/main/java/org/apache/uniffle/shuffle/ShuffleIdMappingManager.java
