diff options
author | CodingCat <zhunansjtu@gmail.com> | 2016-03-15 14:46:21 -0700 |
---|---|---|
committer | Shixiong Zhu <shixiong@databricks.com> | 2016-03-15 14:46:21 -0700 |
commit | dddf2f2d8730a20c06bfa819a4a22f04c807f066 (patch) | |
tree | 4a4c1eb8adc777cf6db939f4ab0d632c257f886f | |
parent | 50e3644d00c75de8273cce191debde68061e6e13 (diff) | |
download | spark-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.
-rw-r--r-- | core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala | 2 |
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( |