diff options
| author | Ding Fei <danis@danix> | 2016-09-26 23:09:51 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-09-26 23:09:51 -0700 |
| commit | 6ee28423ad1b2e6089b82af64a31d77d3552bb38 (patch) | |
| tree | 4f92e6d82d73a9b2c1cc71e52a69855e7adbec4a | |
| parent | 93c743f1aca433144611b11d4e1b169d66e0f57b (diff) | |
| download | spark-6ee28423ad1b2e6089b82af64a31d77d3552bb38.tar.gz spark-6ee28423ad1b2e6089b82af64a31d77d3552bb38.tar.bz2 spark-6ee28423ad1b2e6089b82af64a31d77d3552bb38.zip | |
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.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala | 3 | ||||
| -rw-r--r-- | core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala | 2 |
2 files changed, 3 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala b/core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala index af29de3b08..23efcab6ca 100644 --- a/core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala +++ b/core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala @@ -21,7 +21,8 @@ import org.apache.spark.internal.Logging 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. */ private[spark] class WorkerWatcher( diff --git a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala index c6aebc19fd..bb24c6ce4d 100644 --- a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala +++ b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala @@ -253,7 +253,7 @@ class MapOutputTrackerSuite extends SparkFunSuite { rpcEnv.stop(masterTracker.trackerEndpoint) 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 // being sent. masterTracker.registerShuffle(20, 100) |