HIVE-23929: Run compaction as partition owner (Laszlo Pinter reviewed…

… by Peter Vary) Closes (#1309)
apache · Aug 4, 2020 · 3d85d8bbcf473aea3e3b5a00db662a5d5ea973d7 · 3d85d8b
1 parent fdfd136
commit 3d85d8bbcf473aea3e3b5a00db662a5d5ea973d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java b/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java
@@ -520,7 +520,7 @@ protected Boolean findNextCompactionAndExecute(boolean computeStats) throws Inte
         if (runJobAsSelf(ci.runAs)) {
           mr.run(conf, jobName.toString(), t, p, sd, tblValidWriteIds, ci, su, msc, dir);
         } else {
-          UserGroupInformation ugi = UserGroupInformation.createProxyUser(t.getOwner(),
+          UserGroupInformation ugi = UserGroupInformation.createProxyUser(ci.runAs,
               UserGroupInformation.getLoginUser());
           final Partition fp = p;
           final CompactionInfo fci = ci;