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)