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-no...@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)