diff --git a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java
index 9c563169af0..7630eb2e0dc 100644
--- a/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java
+++ b/phoenix-core/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java
@@ -81,7 +81,7 @@ public void stop() {
 
     @Override
     public boolean dispatch(CallRunner callTask) throws InterruptedException, IOException {
-        ServerCall call = callTask.getCall();
+        RpcCall call = callTask.getRpcCall();
         int priority = call.getHeader().getPriority();
         if (indexPriority == priority) {
             return indexCallExecutor.dispatch(callTask);
diff --git a/phoenix-core/src/test/java/org/apache/hadoop/hbase/ipc/PhoenixIndexRpcSchedulerTest.java b/phoenix-core/src/test/java/org/apache/hadoop/hbase/ipc/PhoenixIndexRpcSchedulerTest.java
index ca4f6b03dc4..031c679559a 100644
--- a/phoenix-core/src/test/java/org/apache/hadoop/hbase/ipc/PhoenixIndexRpcSchedulerTest.java
+++ b/phoenix-core/src/test/java/org/apache/hadoop/hbase/ipc/PhoenixIndexRpcSchedulerTest.java
@@ -119,11 +119,11 @@ private void dispatchCallWithPriority(RpcScheduler scheduler, int priority) thro
         ServerCall call = Mockito.mock(ServerCall.class);
         when(call.getHeader()).thenReturn(header);
         when(call.getRequestUser()).thenReturn(Optional.empty());
-        Mockito.when(task.getCall()).thenReturn(call);
+        Mockito.when(task.getRpcCall()).thenReturn(call);
 
         scheduler.dispatch(task);
 
-        Mockito.verify(task).getCall();
+        Mockito.verify(task).getRpcCall();
         Mockito.verifyNoMoreInteractions(task);
         server.stop();
     }