HIVE-27850: Iceberg: Addendum 2: Set runAs user in CompactionInfo (Dm…

…itriy Fingerman, reviewed by Denys Kuzmenko) Closes #5100
apache · Feb 27, 2024 · 8900565 · 8900565
1 parent 1881c96
commit 8900565
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergCompactionService.java b/...handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergCompactionService.java
@@ -19,6 +19,7 @@
 package org.apache.iceberg.mr.hive.compaction;
 
 import org.apache.hadoop.hive.metastore.api.Table;
+import org.apache.hadoop.hive.metastore.txn.TxnUtils;
 import org.apache.hadoop.hive.metastore.txn.entities.CompactionInfo;
 import org.apache.hadoop.hive.ql.txn.compactor.CompactorContext;
 import org.apache.hadoop.hive.ql.txn.compactor.CompactorPipeline;
@@ -48,6 +49,10 @@ public Boolean compact(Table table, CompactionInfo ci) throws Exception {
     }
     CompactorUtil.checkInterrupt(CLASS_NAME);
 
+    if (ci.runAs == null) {
+      ci.runAs = TxnUtils.findUserToRunAs(table.getSd().getLocation(), table, conf);
+    }
+
     try {
       CompactorPipeline compactorPipeline = compactorFactory.getCompactorPipeline(table, conf, ci, msc);
       computeStats = collectGenericStats;