You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "lvyanquan (Jira)" <ji...@apache.org> on 2023/04/03 03:25:00 UTC
[jira] [Created] (HUDI-6018) create table with Flink will set owner to a full user name in kerberos
lvyanquan created HUDI-6018:
-------------------------------
Summary: create table with Flink will set owner to a full user name in kerberos
Key: HUDI-6018
URL: https://issues.apache.org/jira/browse/HUDI-6018
Project: Apache Hudi
Issue Type: Improvement
Components: flink
Reporter: lvyanquan
{code:java}
private Table instantiateHiveTable(ObjectPath tablePath, CatalogBaseTable table, String location, boolean useRealTimeInputFormat) throws IOException {
// let Hive set default parameters for us, e.g. serialization.format
Table hiveTable =
org.apache.hadoop.hive.ql.metadata.Table.getEmptyTable(
tablePath.getDatabaseName(), tablePath.getObjectName());
hiveTable.setOwner(UserGroupInformation.getCurrentUser().getUserName());
......
return hiveTable;
} {code}
Under kerberos environment, I found that owner of table may beĀ like `hive/devops-hadoop3-krb-node1@DTSTACK.COM` now.
But owner of hive table in kerberos should be like 'hive' or 'hdfs'.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)