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

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


The following commit(s) were added to refs/heads/branch-0.3 by this push:
     new 2bbfdafb3 [CELEBORN-547][FOLLOWUP] Fix wrong method name
2bbfdafb3 is described below

commit 2bbfdafb316d18fef1da1f8e4c87fc6dcfef11fb
Author: Angerszhuuuu <[email protected]>
AuthorDate: Tue Jun 13 12:22:47 2023 +0800

    [CELEBORN-547][FOLLOWUP] Fix wrong method name
    
    ### What changes were proposed in this pull request?
    Fix wrong method name
    
    ### Why are the changes needed?
    
    ### Does this PR introduce _any_ user-facing change?
    
    ### How was this patch tested?
    
    Closes #1582 from AngersZhuuuu/CELEBORN-547-FOLLOWUP.
    
    Authored-by: Angerszhuuuu <[email protected]>
    Signed-off-by: Angerszhuuuu <[email protected]>
    (cherry picked from commit 6177476b18beca2ae20b05b06483c118db74fe5a)
    Signed-off-by: Angerszhuuuu <[email protected]>
---
 .../src/main/scala/org/apache/celeborn/client/LifecycleManager.scala  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala 
b/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
index b17907a0e..792692607 100644
--- a/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
+++ b/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
@@ -402,7 +402,7 @@ class LifecycleManager(appId: String, val conf: 
CelebornConf) extends RpcEndpoin
     // First, request to get allocated slots from Master
     val ids = new util.ArrayList[Integer](numPartitions)
     (0 until numPartitions).foreach(idx => ids.add(new Integer(idx)))
-    val res = requestMasterReleaseSlotsWithRetry(applicationId, shuffleId, ids)
+    val res = requestMasterRequestSlotsWithRetry(applicationId, shuffleId, ids)
 
     res.status match {
       case StatusCode.REQUEST_FAILED =>
@@ -1028,7 +1028,7 @@ class LifecycleManager(appId: String, val conf: 
CelebornConf) extends RpcEndpoin
     }
   }
 
-  private def requestMasterReleaseSlotsWithRetry(
+  private def requestMasterRequestSlotsWithRetry(
       applicationId: String,
       shuffleId: Int,
       ids: util.ArrayList[Integer]): RequestSlotsResponse = {

Reply via email to