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 = {