flink 读带认证的hbase 问题

[venn]

各位大佬：

            请问：flink on yarn 模式（standalone 模式下也不行）下 读带
kerberos 认证的 hbase，返回认证成功了，但是还是不能查询，一直报 “Caused by:
GSSExecption: No valid credentials provided (Mechanism level: Failed to find
any Kerberos tgt)”

发现认证之后，当前用户（UserGroupInformation.getLoginUser ）和登陆用户
（UserGroupInformation.getCurrentUser ）不一样

认证之前，当前用户和登陆用户都是  admin (auth:SIMPLE)            #admin 是登
陆系统的用户

认证之后，当前用户还是 admin (auth:SIMPLE) ，登陆用户变成了认证的那个用户
xxx (auth: KERBEROS)

            程序在IDE  里面可以正常执行，当前用户和登陆用户都是用一个用户，
已确定keytab 文件 是没有问题的

配置应该没有问题，因为其实已经认证成功了，但是看起来执行程序的用户和认证的用
户不是同一个用户，请问各位大佬有了解的吗？

 

非常感谢各位大佬

 

报错如下：

FATAL org.apache.hadoop.ipc.RpcClient  - SASL authentication failed. The
most likely cause is missing or invalid credentials. Consider 'kinit'.

 

javax.security.sasl.SaslException: GSS initiate failed [Caused by
GSSException: No valid credentials provided (Mechanism level: Failed to find
any Kerberos tgt)]

 

Caused by: GSSException: No valid credentials provided (Mechanism level:
Failed to find any Kerberos tgt)