This is an automated email from the ASF dual-hosted git repository.
zuston pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/uniffle.git
The following commit(s) were added to refs/heads/master by this push:
new 741ecba1a [#2691] feat(client): Introduce the `HARD_SPLIT_FROM_SERVER`
response status code (#2694)
741ecba1a is described below
commit 741ecba1a1157f6e2527469282f624748c9d8769
Author: Junfan Zhang <[email protected]>
AuthorDate: Tue Dec 9 17:04:36 2025 +0800
[#2691] feat(client): Introduce the `HARD_SPLIT_FROM_SERVER` response
status code (#2694)
### What changes were proposed in this pull request?
This PR introduces the `HARD_SPLIT_FROM_SERVER` response status code
### Why are the changes needed?
the subtask for the #2691
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
No need
---
common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java | 1 +
.../org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java | 3 ++-
proto/src/main/proto/Rss.proto | 1 +
3 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java
b/common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java
index 6b413c531..3c11e08d1 100644
--- a/common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java
+++ b/common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java
@@ -39,6 +39,7 @@ public enum StatusCode {
EXCEED_HUGE_PARTITION_HARD_LIMIT(12),
APP_NOT_FOUND(13),
INTERNAL_NOT_RETRY_ERROR(14),
+ HARD_SPLIT_FROM_SERVER(15),
UNKNOWN(-1);
static final Map<Integer, StatusCode> VALUE_MAP =
diff --git
a/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java
b/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java
index 2ad920d04..4ba195ede 100644
---
a/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java
+++
b/internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java
@@ -150,7 +150,8 @@ public class ShuffleServerGrpcClient extends GrpcClient
implements ShuffleServer
StatusCode.NO_REGISTER,
StatusCode.APP_NOT_FOUND,
StatusCode.INTERNAL_NOT_RETRY_ERROR,
- StatusCode.EXCEED_HUGE_PARTITION_HARD_LIMIT);
+ StatusCode.EXCEED_HUGE_PARTITION_HARD_LIMIT,
+ StatusCode.HARD_SPLIT_FROM_SERVER);
private ShuffleServerInfo serverInfo;
diff --git a/proto/src/main/proto/Rss.proto b/proto/src/main/proto/Rss.proto
index ec8f3f278..ddccf656e 100644
--- a/proto/src/main/proto/Rss.proto
+++ b/proto/src/main/proto/Rss.proto
@@ -363,6 +363,7 @@ enum StatusCode {
EXCEED_HUGE_PARTITION_HARD_LIMIT = 12;
APP_NOT_FOUND = 13;
INTERNAL_NOT_RETRY_ERROR = 14;
+ HARD_SPLIT_FROM_SERVER = 15;
// add more status
}