aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorCodingCat <zhunansjtu@gmail.com>2016-03-15 14:46:21 -0700
committerShixiong Zhu <shixiong@databricks.com>2016-03-15 14:46:21 -0700
commitdddf2f2d8730a20c06bfa819a4a22f04c807f066 (patch)
tree4a4c1eb8adc777cf6db939f4ab0d632c257f886f /core
parent50e3644d00c75de8273cce191debde68061e6e13 (diff)
downloadspark-dddf2f2d8730a20c06bfa819a4a22f04c807f066.tar.gz
spark-dddf2f2d8730a20c06bfa819a4a22f04c807f066.tar.bz2
spark-dddf2f2d8730a20c06bfa819a4a22f04c807f066.zip
[MINOR] a minor fix for the comments of a method in RPC Dispatcher
## What changes were proposed in this pull request? a minor fix for the comments of a method in RPC Dispatcher ## How was this patch tested? existing unit tests Author: CodingCat <zhunansjtu@gmail.com> Closes #11738 from CodingCat/minor_rpc.
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala b/core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
index 6ceff2c073..f092f1d7f6 100644
--- a/core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
+++ b/core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
@@ -136,7 +136,7 @@ private[netty] class Dispatcher(nettyEnv: NettyRpcEnv) extends Logging {
* Posts a message to a specific endpoint.
*
* @param endpointName name of the endpoint.
- * @param createMessageFn function to create the message.
+ * @param message the message to post
* @param callbackIfStopped callback function if the endpoint is stopped.
*/
private def postMessage(