You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2017/04/12 22:05:43 UTC
hive git commit: HIVE-15851 CompactorMR.launchCompactionJob() should
use JobClient.submitJob() not runJob (Eugene Koifman, reviewed by Wei Zheng)
Repository: hive
Updated Branches:
refs/heads/branch-2.2 3640e6f79 -> 9d7f148ed
HIVE-15851 CompactorMR.launchCompactionJob() should use JobClient.submitJob() not runJob (Eugene Koifman, reviewed by Wei Zheng)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/9d7f148e
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/9d7f148e
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/9d7f148e
Branch: refs/heads/branch-2.2
Commit: 9d7f148edec5a4e4d37d91e78a353bd9e3b6ec1f
Parents: 3640e6f
Author: Eugene Koifman <ek...@hortonworks.com>
Authored: Thu Feb 9 10:14:30 2017 -0800
Committer: Wei Zheng <we...@apache.org>
Committed: Wed Apr 12 15:06:53 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/9d7f148e/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java b/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java
index 37990d8..eb0be9f 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java
@@ -300,7 +300,7 @@ public class CompactorMR {
job.getJobName() + "' to " + job.getQueueName() + " queue. " +
"(current delta dirs count=" + curDirNumber +
", obsolete delta dirs count=" + obsoleteDirNumber + ". TxnIdRange[" + minTxn + "," + maxTxn + "]");
- RunningJob rj = JobClient.runJob(job);
+ RunningJob rj = new JobClient(job).submitJob(job);
LOG.info("Submitted compaction job '" + job.getJobName() + "' with jobID=" + rj.getID() + " compaction ID=" + id);
txnHandler.setHadoopJobId(rj.getID().toString(), id);
rj.waitForCompletion();