在doAs方法中是可以的。我现在hive connector中操作hive涉及认证的代码都在doAs中执行，可以解决认证问题。
前面提到的stacktrace是用我们公司自己封装的hive-exec
jar打印出来的，所以跟源码对应不上，我用官网的hive-exec-2.1.1.jar也是有这个问题。
| |
叶贤勋
|
|
yxx_c...@163.com
|
签名由网易邮箱大师定制
在2020年03月5日 13:52，Rui Li 写道：
这是我和flink社区沟通的记录，你可以看下。
| |
叶贤勋
|
|
yxx_c...@163.com
|
签名由网易邮箱大师定制
在2020年03月3日 16:00，叶贤勋 写道：
hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。
datanucleus的依赖不加的话，会报claas not found等异常。
1、java.lang.ClassNotFoundException:
org.datanucleus.api.jdo.JDOPersistenceManagerFactory
2、Caused by:
hive conf应该是对的，前面UserGroupInfomation登录时都是成功的。
datanucleus的依赖不加的话，会报claas not found等异常。
1、java.lang.ClassNotFoundException:
org.datanucleus.api.jdo.JDOPersistenceManagerFactory
2、Caused by: org.datanucleus.exceptions.NucleusUserException: There is no
available StoreManager of type "rdbms". Please
Hi 李锐，感谢你的回复。
前面的问题通过设置yarn.resourcemanager.principal，已经解决。
但是现在出现另外一个问题，请帮忙看看。
背景：flink任务还是source带有kerberos的hive，相同代码在本地进行测试是能通过kerberos认证，并且能够查询和插入数据到hive。但是任务提交到集群就报kerberos认证失败的错误。
Flink：1.9.1,
