Skip to content

Commit f68fdb1

Browse files
committed
Fix streaming test compilation
1 parent 0b5c72f commit f68fdb1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,7 @@ class ReceivedBlockHandlerSuite
254254
maxMem: Long,
255255
conf: SparkConf,
256256
name: String = SparkContext.DRIVER_IDENTIFIER): BlockManager = {
257-
val memManager = new StaticMemoryManager(conf, Long.MaxValue, maxMem)
257+
val memManager = new StaticMemoryManager(conf, Long.MaxValue, maxMem, numCores = 1)
258258
val transfer = new NettyBlockTransferService(conf, securityMgr, numCores = 1)
259259
val blockManager = new BlockManager(name, rpcEnv, blockManagerMaster, serializer, conf,
260260
memManager, mapOutputTracker, shuffleManager, transfer, securityMgr, 0)

0 commit comments

Comments
 (0)