lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2676] Hudi should synchronize owner information to hudi _rt/_ro table. (#3911)

Browse Source
This commit is contained in:
xiarixiaoyao
2021-11-03 20:36:01 +08:00
committed by GitHub
parent f2fb1aac26
commit acc40625f5
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HMSDDLExecutor.java
View File

@@ -18,6 +18,7 @@
package org.apache.hudi.hive.ddl; package org.apache.hudi.hive.ddl;
import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hudi.common.fs.FSUtils; import org.apache.hudi.common.fs.FSUtils;
import org.apache.hudi.common.fs.StorageSchemes; import org.apache.hudi.common.fs.StorageSchemes;
import org.apache.hudi.hive.HiveSyncConfig; import org.apache.hudi.hive.HiveSyncConfig;
@@ -101,6 +102,7 @@ public class HMSDDLExecutor implements DDLExecutor {
Table newTb = new Table(); Table newTb = new Table();
newTb.setDbName(syncConfig.databaseName); newTb.setDbName(syncConfig.databaseName);
newTb.setTableName(tableName); newTb.setTableName(tableName);
newTb.setOwner(UserGroupInformation.getCurrentUser().getShortUserName());
newTb.setCreateTime((int) System.currentTimeMillis()); newTb.setCreateTime((int) System.currentTimeMillis());
StorageDescriptor storageDescriptor = new StorageDescriptor(); StorageDescriptor storageDescriptor = new StorageDescriptor();
storageDescriptor.setCols(fieldSchema); storageDescriptor.setCols(fieldSchema);