File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
main/scala/org/apache/spark/deploy/worker
test/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -21,7 +21,8 @@ import org.apache.spark.internal.Logging
2121import org .apache .spark .rpc ._
2222
2323/**
24- * WorkerWatcher RpcEndpoint 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 */
2728private [spark] class WorkerWatcher (
Original file line number Diff line number Diff 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 )
You can’t perform that action at this time.
0 commit comments