diff options
| author | Aaron Davidson <aaron@databricks.com> | 2014-11-12 18:46:37 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-11-12 18:46:37 -0800 |
| commit | b9e1c2eb9b6f7fb609718ef20048a8da452d881b (patch) | |
| tree | ae44b633e68d4fd021846859ad578b7c891fab5d /streaming | |
| parent | 23f5bdf06a388e08ea5a69e848f0ecd5165aa481 (diff) | |
| download | spark-b9e1c2eb9b6f7fb609718ef20048a8da452d881b.tar.gz spark-b9e1c2eb9b6f7fb609718ef20048a8da452d881b.tar.bz2 spark-b9e1c2eb9b6f7fb609718ef20048a8da452d881b.zip | |
[SPARK-4370] [Core] Limit number of Netty cores based on executor size
Author: Aaron Davidson <aaron@databricks.com>
Closes #3155 from aarondav/conf and squashes the following commits:
7045e77 [Aaron Davidson] Add mesos comment
4770f6e [Aaron Davidson] [SPARK-4370] [Core] Limit number of Netty cores based on executor size
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala index 9efe15d01e..3661e16a9e 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala @@ -73,7 +73,7 @@ class ReceivedBlockHandlerSuite extends FunSuite with BeforeAndAfter with Matche blockManager = new BlockManager("bm", actorSystem, blockManagerMaster, serializer, blockManagerSize, conf, mapOutputTracker, shuffleManager, - new NioBlockTransferService(conf, securityMgr), securityMgr) + new NioBlockTransferService(conf, securityMgr), securityMgr, 0) blockManager.initialize("app-id") tempDirectory = Files.createTempDir() |