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 6ceff2c073998..f092f1d7f64d7 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(