[incubator-celeborn] branch main updated: [CELEBORN-196][REFACTOR] Rename batchHandleRequestPartitions to handleRequestPartitions (#1144)

[angerszhuuuu]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new fe8dfb05 [CELEBORN-196][REFACTOR] Rename batchHandleRequestPartitions 
to handleRequestPartitions (#1144)
fe8dfb05 is described below

commit fe8dfb05f3ea7ee83ffbe2ef9dcb789a80f1c5b3
Author: Angerszhuuuu <angers....@gmail.com>
AuthorDate: Thu Jan 5 14:37:10 2023 +0800

    [CELEBORN-196][REFACTOR] Rename batchHandleRequestPartitions to 
handleRequestPartitions (#1144)
---
 .../scala/org/apache/celeborn/client/ChangePartitionManager.scala   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala 
b/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala
index 0547692c..d7daebaa 100644
--- 
a/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala
+++ 
b/client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala
@@ -88,7 +88,7 @@ class ChangePartitionManager(
                           request.asScala.toArray.maxBy(_.epoch)
                         }.toArray
                         if (distinctPartitions.nonEmpty) {
-                          batchHandleRequestPartitions(
+                          handleRequestPartitions(
                             distinctPartitions.head.applicationId,
                             shuffleId,
                             distinctPartitions)
@@ -175,7 +175,7 @@ class ChangePartitionManager(
       }
     }
     if (!batchHandleChangePartitionEnabled) {
-      batchHandleRequestPartitions(applicationId, shuffleId, 
Array(changePartition))
+      handleRequestPartitions(applicationId, shuffleId, Array(changePartition))
     }
   }
 
@@ -193,7 +193,7 @@ class ChangePartitionManager(
     None
   }
 
-  def batchHandleRequestPartitions(
+  def handleRequestPartitions(
       applicationId: String,
       shuffleId: Int,
       changePartitions: Array[ChangePartitionRequest]): Unit = {