ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[MINOR] a minor fix for the comments of a method in RPC Dispatcher

Browse source 
## 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.
This commit is contained in:
CodingCat 2016-03-15 14:46:21 -07:00 committed by Shixiong Zhu
parent 50e3644d00
commit dddf2f2d87
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
View file

@ -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(