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 <47777102+laszlopinte...@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;