[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521407#comment-17521407 ]
luoyuxia commented on FLINK-27191: ---------------------------------- About the confict with TM's, the idea is when every call involving with hdfs/hive metastore, switch the user like using the following code: {code:java} final Configuration conf = new Configuration(); UserGroupInformation ugi = UserGroupInformation.loginUserFromKeytabAndReturnUGI(userCode, keytabPath); ugi.doAs(new PrivilegedAction<Object>() { @Override public Object run() { // access hdfs/hive metastore } });{code} So that's why we may need a wrapper. > Support multi kerberos-enabled Hive clusters > --------------------------------------------- > > Key: FLINK-27191 > URL: https://issues.apache.org/jira/browse/FLINK-27191 > Project: Flink > Issue Type: Improvement > Components: Connectors / Hive > Reporter: luoyuxia > Priority: Major > Fix For: 1.16.0 > > > Currently, to access kerberos-enabled Hive cluster, users are expected to add > key/secret in flink-conf. But it can only access one Hive cluster in one > Flink cluster, we are also expected to support multi kerberos-enabled Hive > clusters in one Flink cluster. -- This message was sent by Atlassian Jira (v8.20.1#820001)