You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by vj...@apache.org on 2021/11/29 10:15:18 UTC
[phoenix] branch 5.1 updated: PHOENIX-6600 Replace deprecated getCall with updated getRpcCall (#1361) (#1356)
This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a commit to branch 5.1
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.1 by this push:
new ddc6028 PHOENIX-6600 Replace deprecated getCall with updated getRpcCall (#1361) (#1356)
ddc6028 is described below
commit ddc602881de6aac42b7905b41d1d13e1d06b3fa2
Author: kiran.maturi <ma...@gmail.com>
AuthorDate: Mon Nov 29 15:45:13 2021 +0530
PHOENIX-6600 Replace deprecated getCall with updated getRpcCall (#1361) (#1356)
Signed-off-by: Viraj Jasani <vj...@apache.org>
---
.../main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java | 2 +-
.../org/apache/hadoop/hbase/ipc/PhoenixIndexRpcSchedulerTest.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
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 9c56316..7630eb2 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 class PhoenixRpcScheduler extends CompatPhoenixRpcScheduler {
@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 ca4f6b0..031c679 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 @@ public class PhoenixIndexRpcSchedulerTest {
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();
}