[
https://issues.apache.org/jira/browse/HUDI-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen closed HUDI-6018.
----------------------------
Assignee: Danny Chen
Resolution: Fixed
Fixed via master branch: 72c5288bd23167f801fb89941e19771ea7b3b2fe
> 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
> Assignee: Danny Chen
> Priority: Major
> Labels: pull-request-available
>
> {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)
