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/[email protected]` 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)
