diff options
Diffstat (limited to 'core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java')
-rw-r--r-- | core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java b/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java index d5de56a051..642f6585f8 100644 --- a/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java +++ b/core/src/test/java/org/apache/spark/util/collection/unsafe/sort/UnsafeInMemorySorterSuite.java @@ -20,17 +20,19 @@ package org.apache.spark.util.collection.unsafe.sort; import java.util.Arrays; import org.junit.Test; -import static org.hamcrest.MatcherAssert.assertThat; -import static org.hamcrest.Matchers.*; -import static org.junit.Assert.*; -import static org.mockito.Mockito.mock; import org.apache.spark.HashPartitioner; import org.apache.spark.SparkConf; +import org.apache.spark.memory.TestMemoryManager; +import org.apache.spark.memory.TaskMemoryManager; import org.apache.spark.unsafe.Platform; -import org.apache.spark.memory.GrantEverythingMemoryManager; import org.apache.spark.unsafe.memory.MemoryBlock; -import org.apache.spark.memory.TaskMemoryManager; + +import static org.hamcrest.MatcherAssert.assertThat; +import static org.hamcrest.Matchers.greaterThanOrEqualTo; +import static org.hamcrest.Matchers.isIn; +import static org.junit.Assert.assertEquals; +import static org.mockito.Mockito.mock; public class UnsafeInMemorySorterSuite { @@ -44,7 +46,7 @@ public class UnsafeInMemorySorterSuite { public void testSortingEmptyInput() { final UnsafeInMemorySorter sorter = new UnsafeInMemorySorter( new TaskMemoryManager( - new GrantEverythingMemoryManager(new SparkConf().set("spark.unsafe.offHeap", "false")), 0), + new TestMemoryManager(new SparkConf().set("spark.unsafe.offHeap", "false")), 0), mock(RecordComparator.class), mock(PrefixComparator.class), 100); @@ -66,8 +68,8 @@ public class UnsafeInMemorySorterSuite { "Mango" }; final TaskMemoryManager memoryManager = new TaskMemoryManager( - new GrantEverythingMemoryManager(new SparkConf().set("spark.unsafe.offHeap", "false")), 0); - final MemoryBlock dataPage = memoryManager.allocatePage(2048); + new TestMemoryManager(new SparkConf().set("spark.unsafe.offHeap", "false")), 0); + final MemoryBlock dataPage = memoryManager.allocatePage(2048, null); final Object baseObject = dataPage.getBaseObject(); // Write the records into the data page: long position = dataPage.getBaseOffset(); |