change variable name

apache · Sep 20, 2024 · 8c65ac9 · 8c65ac9
1 parent 84a795a
commit 8c65ac9
Showing 1 changed file with 2 additions and 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
@@ -103,7 +103,7 @@ class LifecycleManager(val appUniqueId: String, val conf: CelebornConf) extends
   private val rpcCacheExpireTime = conf.clientRpcCacheExpireTime
   private val rpcMaxRetires = conf.clientRpcMaxRetries
 
-  private val batchRemoveExpiredShuffles = conf.batchHandleRemoveExpiredShufflesEnabled
+  private val batchRemoveExpiredShufflesEnabled = conf.batchHandleRemoveExpiredShufflesEnabled
 
   private val excludedWorkersFilter = conf.registerShuffleFilterExcludedWorkerEnabled
 
@@ -1592,7 +1592,7 @@ class LifecycleManager(val appUniqueId: String, val conf: CelebornConf) extends
         latestPartitionLocation.remove(shuffleId)
         commitManager.removeExpiredShuffle(shuffleId)
         changePartitionManager.removeExpiredShuffle(shuffleId)
-        if (!batchRemoveExpiredShuffles) {
+        if (!batchRemoveExpiredShufflesEnabled) {
           val unregisterShuffleResponse = requestMasterUnregisterShuffle(
             UnregisterShuffle(appUniqueId, shuffleId, MasterClient.genRequestId()))
           // if unregister shuffle not success, wait next turn