Skip to content

Commit 6ff9953

Browse files
committed
fix style issues
1 parent 916991e commit 6ff9953

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

core/src/main/scala/org/apache/spark/ResourceInformation.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,4 +43,4 @@ case class ResourceInformation(
4343
def getUnits(): String = units
4444
def getCount(): Long = count
4545
def getAddresses(): Array[String] = addresses
46-
}
46+
}

core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,8 @@ private[spark] class CoarseGrainedExecutorBackend(
9393
}
9494
val resType = typeAndValue(0)
9595
// format should be: count:unit:addr1,addr2,addr3
96-
val singleResourceInfo = ResourceDiscoverer.parseResourceTypeString(resType, typeAndValue(1))
96+
val singleResourceInfo =
97+
ResourceDiscoverer.parseResourceTypeString(resType, typeAndValue(1))
9798
(resType, singleResourceInfo)
9899
}).toMap
99100
allResourceTypes
@@ -359,7 +360,7 @@ private[spark] object CoarseGrainedExecutorBackend extends Logging {
359360
| --executor-id <executorId>
360361
| --hostname <hostname>
361362
| --cores <cores>
362-
| --resourceAddrs <resourceType=count:unit:addr1,addr2,addr3;resourceType2=count:unit:r2addr1,r2addr2,...>
363+
| --resourceAddrs <rtype1=count:unit:addr1,addr2;rtype2=count:unit:r2addr1,r2addr2...>
363364
| --app-id <appid>
364365
| --worker-url <workerUrl>
365366
| --user-class-path <url>

core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedClusterMessage.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.scheduler.cluster
2020
import java.nio.ByteBuffer
2121

2222
import org.apache.spark.ResourceInformation
23-
2423
import org.apache.spark.TaskState.TaskState
2524
import org.apache.spark.rpc.RpcEndpointRef
2625
import org.apache.spark.scheduler.ExecutorLossReason

0 commit comments

Comments
 (0)