File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
core/src/main/scala/org/apache/spark/deploy/worker Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,8 @@ import org.apache.spark.network.shuffle.ExternalShuffleBlockHandler
32
32
* Optionally requires SASL authentication in order to read. See [[SecurityManager ]].
33
33
*/
34
34
private [worker]
35
- class WorkerShuffleService (sparkConf : SparkConf , securityManager : SecurityManager ) extends Logging {
35
+ class StandaloneWorkerShuffleService (sparkConf : SparkConf , securityManager : SecurityManager )
36
+ extends Logging {
36
37
37
38
private val enabled = sparkConf.getBoolean(" spark.shuffle.service.enabled" , false )
38
39
private val port = sparkConf.getInt(" spark.shuffle.service.port" , 7337 )
Original file line number Diff line number Diff line change @@ -112,7 +112,7 @@ private[spark] class Worker(
112
112
val finishedDrivers = new HashMap [String , DriverRunner ]
113
113
114
114
// The shuffle service is not actually started unless configured.
115
- var shuffleService = new WorkerShuffleService (conf, securityMgr)
115
+ val shuffleService = new StandaloneWorkerShuffleService (conf, securityMgr)
116
116
117
117
val publicAddress = {
118
118
val envVar = System .getenv(" SPARK_PUBLIC_DNS" )
You can’t perform that action at this time.
0 commit comments