Skip to content

Commit 6ee2842

Browse files
Ding Feirxin
authored andcommitted
Fix two comments since Actor is not used anymore.
## What changes were proposed in this pull request? Fix two comments since Actor is not used anymore. Author: Ding Fei <danis@danix> Closes #15251 from danix800/comment-fixing.
1 parent 93c743f commit 6ee2842

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@ import org.apache.spark.internal.Logging
2121
import org.apache.spark.rpc._
2222

2323
/**
24-
* Actor which connects to a worker process and terminates the JVM if the connection is severed.
24+
* Endpoint which connects to a worker process and terminates the JVM if the
25+
* connection is severed.
2526
* Provides fate sharing between a worker and its associated child processes.
2627
*/
2728
private[spark] class WorkerWatcher(

core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,7 @@ class MapOutputTrackerSuite extends SparkFunSuite {
253253
rpcEnv.stop(masterTracker.trackerEndpoint)
254254
rpcEnv.setupEndpoint(MapOutputTracker.ENDPOINT_NAME, masterEndpoint)
255255

256-
// Frame size should be ~1.1MB, and MapOutputTrackerMasterActor should throw exception.
256+
// Frame size should be ~1.1MB, and MapOutputTrackerMasterEndpoint should throw exception.
257257
// Note that the size is hand-selected here because map output statuses are compressed before
258258
// being sent.
259259
masterTracker.registerShuffle(20, 100)

0 commit comments

Comments
 (0)