You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by re...@apache.org on 2023/03/29 02:23:21 UTC

[incubator-celeborn] 06/42: [CELEBORN-393] responseBuilder.setCmdType should be called only once in MetaHandler's handleReadRequest method (#1322)

This is an automated email from the ASF dual-hosted git repository.

rexxiong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git

commit a536ac4239b732781952c3c5a72befc921735e37
Author: jiaoqingbo <11...@qq.com>
AuthorDate: Fri Mar 10 21:17:22 2023 +0800

    [CELEBORN-393] responseBuilder.setCmdType should be called only once in MetaHandler's handleReadRequest method (#1322)
---
 .../celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java      | 2 --
 1 file changed, 2 deletions(-)

diff --git a/master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java b/master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java
index 839cefa59..a890ac1ff 100644
--- a/master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java
+++ b/master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java
@@ -68,7 +68,6 @@ public class MetaHandler {
   public ResourceResponse handleReadRequest(ResourceProtos.ResourceRequest request) {
     ResourceProtos.Type cmdType = request.getCmdType();
     ResourceResponse.Builder responseBuilder = getMasterMetaResponseBuilder(request);
-    responseBuilder.setCmdType(cmdType);
     try {
       switch (cmdType) {
         default:
@@ -88,7 +87,6 @@ public class MetaHandler {
   public ResourceResponse handleWriteRequest(ResourceProtos.ResourceRequest request) {
     ResourceProtos.Type cmdType = request.getCmdType();
     ResourceResponse.Builder responseBuilder = getMasterMetaResponseBuilder(request);
-    responseBuilder.setCmdType(cmdType);
     try {
       String shuffleKey;
       String appId;