[hive] branch master updated: HIVE-23929: Run compaction as partition owner (Laszlo Pinter reviewed by Peter Vary)

[pv...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pvary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 3d85d8b  HIVE-23929: Run compaction as partition owner (Laszlo Pinter reviewed by Peter Vary)
3d85d8b is described below

commit 3d85d8bbcf473aea3e3b5a00db662a5d5ea973d7
Author: László Pintér <47...@users.noreply.github.com>
AuthorDate: Tue Aug 4 12:17:18 2020 +0200

    HIVE-23929: Run compaction as partition owner (Laszlo Pinter reviewed by Peter Vary)
    
    Closes (#1309)
---
 ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 784c95b..91898ee 100644
--- 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 @@ public class Worker extends RemoteCompactorThread implements MetaStoreThread {
         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;