HIVE-21020: log which table/partition is being processed by a txn in Worker (Eugene Koifman, reviewed by Jason Dere, Igor Kryvenko)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/e8e0396c Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/e8e0396c Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/e8e0396c Branch: refs/heads/master Commit: e8e0396c17bd126e116d0326279ed6da91e9ea37 Parents: 7a3cac2 Author: Eugene Koifman <ekoif...@apache.org> Authored: Thu Dec 13 15:54:53 2018 -0800 Committer: Eugene Koifman <ekoif...@apache.org> Committed: Thu Dec 13 15:54:53 2018 -0800 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/e8e0396c/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java ---------------------------------------------------------------------- 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 4a1cac1..2104341 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 @@ -18,6 +18,7 @@ package org.apache.hadoop.hive.ql.txn.compactor; import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.hive.common.JavaUtils; import org.apache.hadoop.hive.common.ValidCompactorWriteIdList; import org.apache.hadoop.hive.common.ValidTxnList; import org.apache.hadoop.hive.metastore.api.AbortTxnRequest; @@ -198,7 +199,7 @@ public class Worker extends CompactorThread { jobName.append("-compactor-"); jobName.append(ci.getFullPartitionName()); - LOG.info("Starting " + ci.type.toString() + " compaction for " + ci.getFullPartitionName()); + LOG.info("Starting " + ci.type.toString() + " compaction for " + ci.getFullPartitionName() + " in " + JavaUtils.txnIdToString(compactorTxnId)); final StatsUpdater su = StatsUpdater.init(ci, txnHandler.findColumnsWithStats(ci), conf, runJobAsSelf(runAs) ? runAs : t.getOwner()); final CompactorMR mr = new CompactorMR();
