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/incubator-uniffle.git
from 1051d2635 [#1608][part-1] fix(spark): Only share the replacement
servers for faulty servers in one stage (#1609)
add f9d71daaa [#1606] feat(client): Add client retry mechanism for
NO_BUFFER when reading data(memory/local/index) (#1616)
No new revisions were added by this update.
Summary of changes:
.../hadoop/mapreduce/task/reduce/RssShuffle.java | 9 +
.../spark/shuffle/reader/RssShuffleReader.java | 10 +
.../spark/shuffle/reader/RssShuffleReader.java | 10 +
.../client/factory/ShuffleClientFactory.java | 20 ++
.../uniffle/client/impl/ShuffleReadClientImpl.java | 2 +
.../apache/uniffle/test/RpcClientRetryTest.java | 277 +++++++++++++++++++++
.../client/impl/grpc/ShuffleServerGrpcClient.java | 157 ++++++++----
.../impl/grpc/ShuffleServerGrpcNettyClient.java | 95 ++++---
...teStorageRequest.java => RetryableRequest.java} | 16 +-
.../request/RssGetInMemoryShuffleDataRequest.java | 25 +-
.../client/request/RssGetShuffleDataRequest.java | 27 +-
.../client/request/RssGetShuffleIndexRequest.java | 25 +-
.../apache/uniffle/server/ShuffleServerConf.java | 6 -
.../uniffle/server/ShuffleServerGrpcService.java | 12 +-
.../server/buffer/ShuffleBufferManager.java | 42 ++--
.../server/netty/ShuffleServerNettyHandler.java | 12 +-
.../server/MockedShuffleServerGrpcService.java | 91 ++++++-
.../storage/factory/ShuffleHandlerFactory.java | 8 +-
.../handler/impl/LocalFileClientReadHandler.java | 32 ++-
.../handler/impl/MemoryClientReadHandler.java | 34 ++-
.../request/CreateShuffleReadHandlerRequest.java | 18 ++
.../impl/LocalFileServerReadHandlerTest.java | 5 +-
22 files changed, 779 insertions(+), 154 deletions(-)
create mode 100644
integration-test/common/src/test/java/org/apache/uniffle/test/RpcClientRetryTest.java
copy
internal-client/src/main/java/org/apache/uniffle/client/request/{RssFetchRemoteStorageRequest.java
=> RetryableRequest.java} (76%)
