From f7e7568414692989215d97abce9dda2fe172abb4 Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Tue, 30 Sep 2014 12:28:21 -0700 Subject: [PATCH] Fixed spark.shuffle.io.receiveBuffer setting. --- .../main/scala/org/apache/spark/network/netty/NettyConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala b/core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala index d5078e417d6d2..7c3074e939794 100644 --- a/core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala +++ b/core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala @@ -53,7 +53,7 @@ class NettyConfig(conf: SparkConf) { * buffer size should be ~ 1.25MB */ private[netty] val receiveBuf: Option[Int] = - conf.getOption("spark.shuffle.io.sendBuffer").map(_.toInt) + conf.getOption("spark.shuffle.io.receiveBuffer").map(_.toInt) /** Send buffer size (SO_SNDBUF). */ private[netty] val sendBuf: Option[Int] =