Skip to content
Snippets Groups Projects
Commit 6ee28423 authored by Ding Fei's avatar Ding Fei Committed by Reynold Xin
Browse files

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.
parent 93c743f1
No related branches found
Tags v2.1.1
No related merge requests found
...@@ -21,7 +21,8 @@ import org.apache.spark.internal.Logging ...@@ -21,7 +21,8 @@ import org.apache.spark.internal.Logging
import org.apache.spark.rpc._ import org.apache.spark.rpc._
/** /**
* Actor which connects to a worker process and terminates the JVM if the connection is severed. * Endpoint which connects to a worker process and terminates the JVM if the
* connection is severed.
* Provides fate sharing between a worker and its associated child processes. * Provides fate sharing between a worker and its associated child processes.
*/ */
private[spark] class WorkerWatcher( private[spark] class WorkerWatcher(
......
...@@ -253,7 +253,7 @@ class MapOutputTrackerSuite extends SparkFunSuite { ...@@ -253,7 +253,7 @@ class MapOutputTrackerSuite extends SparkFunSuite {
rpcEnv.stop(masterTracker.trackerEndpoint) rpcEnv.stop(masterTracker.trackerEndpoint)
rpcEnv.setupEndpoint(MapOutputTracker.ENDPOINT_NAME, masterEndpoint) rpcEnv.setupEndpoint(MapOutputTracker.ENDPOINT_NAME, masterEndpoint)
// Frame size should be ~1.1MB, and MapOutputTrackerMasterActor should throw exception. // Frame size should be ~1.1MB, and MapOutputTrackerMasterEndpoint should throw exception.
// Note that the size is hand-selected here because map output statuses are compressed before // Note that the size is hand-selected here because map output statuses are compressed before
// being sent. // being sent.
masterTracker.registerShuffle(20, 100) masterTracker.registerShuffle(20, 100)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment