Uploaded image for project: 'Apache Hudi'
  1. Apache Hudi
  2. HUDI-6018

create table with Flink will set owner to a full user name in kerberos

    XMLWordPrintableJSON

Details

    Description

      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;
      } 

      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'.

      Attachments

        Issue Links

          Activity

            People

              danny0405 Danny Chen
              1365976815@qq.com lvyanquan
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: