Skip to content

Commit f7e7568

Browse files
rxinaarondav
authored andcommitted
Fixed spark.shuffle.io.receiveBuffer setting.
1 parent 5d98ce3 commit f7e7568

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ class NettyConfig(conf: SparkConf) {
5353
* buffer size should be ~ 1.25MB
5454
*/
5555
private[netty] val receiveBuf: Option[Int] =
56-
conf.getOption("spark.shuffle.io.sendBuffer").map(_.toInt)
56+
conf.getOption("spark.shuffle.io.receiveBuffer").map(_.toInt)
5757

5858
/** Send buffer size (SO_SNDBUF). */
5959
private[netty] val sendBuf: Option[Int] =

0 commit comments

Comments
 (0)