apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[MINOR] Avoid use _$eq in Scala file

Browse Source 
### What changes were proposed in this pull request?

### Why are the changes needed?

### Does this PR introduce _any_ user-facing change?

### How was this patch tested?

Closes #3208 from cxzl25/minor_eq.

Authored-by: sychen <sychen@ctrip.com>
Signed-off-by: mingji <fengmingxiao.fmx@alibaba-inc.com>
This commit is contained in:
sychen 2025-04-11 13:47:41 +08:00 committed by mingji
parent 91814602fc
commit 529fd6e017
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala
View File

@ -180,8 +180,8 @@ class WorkerInfo(
def updateDiskSlots(estimatedPartitionSize: Long): Unit = this.synchronized {
diskInfos.asScala.foreach { case (_, disk) =>
disk.maxSlots_$eq(disk.totalSpace / estimatedPartitionSize)
disk.availableSlots_$eq(disk.actualUsableSpace / estimatedPartitionSize)
disk.maxSlots = disk.totalSpace / estimatedPartitionSize
disk.availableSlots = disk.actualUsableSpace / estimatedPartitionSize
}
}

2
common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala
View File

@ -276,7 +276,7 @@ object PbSerDeUtils {
disks,
userResourceConsumption)
if (masterPersistWorkerNetworkLocation) {
workerInfo.networkLocation_$eq(pbWorkerInfo.getNetworkLocation)
workerInfo.networkLocation = pbWorkerInfo.getNetworkLocation
}
workerInfo
}

2
common/src/test/scala/org/apache/celeborn/common/meta/WorkerInfoSuite.scala
View File

@ -235,7 +235,7 @@ class WorkerInfoSuite extends CelebornFunSuite {
val worker1 = new WorkerInfo("h1", 10001, 10002, 10003, 1000, 10004)
val worker2 =
new WorkerInfo("h2", 20001, 20002, 20003, 2000, 20004, null, null)
worker2.networkLocation_$eq("/1")
worker2.networkLocation = "/1"
val worker3 = new WorkerInfo(
"h3",

2
common/src/test/scala/org/apache/celeborn/common/util/PbSerDeUtilsTest.scala
View File

@ -125,7 +125,7 @@ class PbSerDeUtilsTest extends CelebornFunSuite {
1005,
diskInfos,
userResourceConsumption)
workerInfo1.networkLocation_$eq("/1")
workerInfo1.networkLocation = "/1"
val workerInfo2 =
new WorkerInfo(
"localhost",