-
Type:
Bug
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.1.0
-
Component/s: Spark Core
-
Labels:None
Here is a unit test to demonstrate it:
test("threads should not be granted a negative size") { val manager = new ShuffleMemoryManager(1000L) manager.tryToAcquire(700L) val latch = new CountDownLatch(1) startThread("t1") { manager.tryToAcquire(300L) latch.countDown() } latch.await() // Wait until `t1` calls `tryToAcquire` val granted = manager.tryToAcquire(300L) assert(0 === granted, "granted is negative") }
It outputs "0 did not equal -200 granted is negative"