diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestFairCallQueue.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestFairCallQueue.java index d5e5f90b2f1..96dea803764 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestFairCallQueue.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestFairCallQueue.java @@ -32,7 +32,6 @@ import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.conf.Configuration; -import org.mockito.Matchers; public class TestFairCallQueue extends TestCase { private FairCallQueue fcq; @@ -52,14 +51,6 @@ private Schedulable mockCall(String id) { return mockCall(id, 0); } - // A scheduler which always schedules into priority zero - private RpcScheduler alwaysZeroScheduler; - { - RpcScheduler sched = mock(RpcScheduler.class); - when(sched.getPriorityLevel(Matchers.any())).thenReturn(0); // always queue 0 - alwaysZeroScheduler = sched; - } - @SuppressWarnings("deprecation") public void setUp() { Configuration conf = new Configuration(); @@ -124,7 +115,6 @@ public void testOfferFailsWhenFull() { public void testOfferSucceedsWhenScheduledLowPriority() { // Scheduler will schedule into queue 0 x 5, then queue 1 - RpcScheduler sched = mock(RpcScheduler.class); int mockedPriorities[] = {0, 0, 0, 0, 0, 1, 0}; for (int i = 0; i < 5; i++) { assertTrue(fcq.offer(mockCall("c", mockedPriorities[i]))); }