[hbase] branch branch-2.2 updated: HBASE-23175 Yarn unable to acquire delegation token for HBase Spark jobs

[zghao]

This is an automated email from the ASF dual-hosted git repository.

zghao pushed a commit to branch branch-2.2
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-2.2 by this push:
     new c02f652  HBASE-23175 Yarn unable to acquire delegation token for HBase 
Spark jobs
c02f652 is described below

commit c02f652550f5addf5c9bd862928c7efe5563fd83
Author: Ankit Singhal <ankitsingha...@gmail.com>
AuthorDate: Wed Oct 30 14:49:04 2019 -0700

    HBASE-23175 Yarn unable to acquire delegation token for HBase Spark jobs
---
 .../org/apache/hadoop/hbase/security/token/TokenUtil.java  | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/token/TokenUtil.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/token/TokenUtil.java
index c54d905..4208ec7 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/token/TokenUtil.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/token/TokenUtil.java
@@ -32,6 +32,7 @@ import org.apache.hadoop.hbase.TableName;
 import org.apache.hadoop.hbase.client.Connection;
 import org.apache.hadoop.hbase.client.Table;
 import org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel;
+import org.apache.hadoop.hbase.client.ConnectionFactory;
 import org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos;
 import org.apache.hadoop.hbase.security.User;
 import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
@@ -63,6 +64,19 @@ public class TokenUtil {
   }
 
   /**
+   * It was removed in HBase-2.0 but added again as spark code relies on this 
method to obtain
+   * delegation token
+   * @deprecated Since 2.0.0.
+   */
+  @Deprecated
+  public static Token<AuthenticationTokenIdentifier> obtainToken(Configuration 
conf)
+      throws IOException {
+    try (Connection connection = ConnectionFactory.createConnection(conf)) {
+      return obtainToken(connection);
+    }
+  }
+
+  /**
    * Obtain and return an authentication token for the current user.
    * @param conn The HBase cluster connection
    * @throws IOException if a remote error or serialization problem occurs.