hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [1/2] hbase git commit: HBASE-13445 RpcServer.Call change in backport of HBASE-13397 not sufficiently backwards compatible
Date Fri, 10 Apr 2015 01:40:59 GMT
Repository: hbase
Updated Branches:
  refs/heads/0.98 0324a273f -> bbf8bf436


HBASE-13445 RpcServer.Call change in backport of HBASE-13397 not sufficiently backwards compatible


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9f767463
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9f767463
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9f767463

Branch: refs/heads/0.98
Commit: 9f767463d7129c888129f142f9a73d6e902000fd
Parents: 0324a27
Author: Andrew Purtell <apurtell@apache.org>
Authored: Thu Apr 9 18:32:05 2015 -0700
Committer: Andrew Purtell <apurtell@apache.org>
Committed: Thu Apr 9 18:33:43 2015 -0700

----------------------------------------------------------------------
 .../src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/9f767463/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
index 0e7efb9..2cc71a3 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java
@@ -327,7 +327,11 @@ public class RpcServer implements RpcServerInterface {
       this.isError = false;
       this.size = size;
       this.tinfo = tinfo;
-      this.user = connection.user == null? null: userProvider.create(connection.user);
+      if (connection != null && connection.user != null) {
+        this.user = userProvider.create(connection.user);
+      } else {
+        this.user = null;
+      }
       this.remoteAddress = remoteAddress;
     }
 


Mime
View raw message