You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/09/27 06:09:56 UTC
spark git commit: Fix two comments since Actor is not used anymore.
Repository: spark
Updated Branches:
refs/heads/master 93c743f1a -> 6ee28423a
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 <da...@danix>
Closes #15251 from danix800/comment-fixing.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/6ee28423
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/6ee28423
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/6ee28423
Branch: refs/heads/master
Commit: 6ee28423ad1b2e6089b82af64a31d77d3552bb38
Parents: 93c743f
Author: Ding Fei <da...@danix>
Authored: Mon Sep 26 23:09:51 2016 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Mon Sep 26 23:09:51 2016 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala | 3 ++-
core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala | 2 +-
2 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/6ee28423/core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala
----------------------------------------------------------------------
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 af29de3..23efcab 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(
http://git-wip-us.apache.org/repos/asf/spark/blob/6ee28423/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
index c6aebc1..bb24c6c 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org