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 6bc12b8e8..1b44c14bb 100644 --- a/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala +++ b/client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala @@ -329,8 +329,10 @@ class LifecycleManager(val appUniqueId: String, val conf: CelebornConf) extends rpcEnv.address.port } + private val partitionType = conf.shufflePartitionType + def getPartitionType(shuffleId: Int): PartitionType = { - shufflePartitionType.getOrDefault(shuffleId, conf.shufflePartitionType) + shufflePartitionType.getOrDefault(shuffleId, partitionType) } override def receive: PartialFunction[Any, Unit] = {