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 159f81e8db..dbe0bf358d 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 @@ -23,6 +23,7 @@ import java.util.concurrent.CompletableFuture; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.AsyncConnection; import org.apache.hadoop.hbase.client.Connection; +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.zookeeper.ZKClusterId; @@ -57,6 +58,18 @@ public class TokenUtil { return ClientTokenUtil.obtainToken(conn); } + /** + * It was removed in HBase-2.0 but added again as spark code relies on this method to obtain + * delegation token + */ + @Deprecated + public static Token obtainToken(Configuration conf) + throws IOException { + try (Connection connection = ConnectionFactory.createConnection(conf)) { + return obtainToken(connection); + } + } + /** * See {@link ClientTokenUtil#obtainToken(org.apache.hadoop.hbase.client.Connection)}. * @deprecated External users should not use this method. Please post on