From b9e1c2eb9b6f7fb609718ef20048a8da452d881b Mon Sep 17 00:00:00 2001 From: Aaron Davidson Date: Wed, 12 Nov 2014 18:46:37 -0800 Subject: [SPARK-4370] [Core] Limit number of Netty cores based on executor size Author: Aaron Davidson 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 --- .../scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'streaming') 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() -- cgit v1.2.3