diff --git ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java index 05b6fc4..f74cab7 100644 --- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java +++ ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/CompactorMR.java @@ -309,7 +309,16 @@ private void launchCompactionJob(JobConf job, Path baseDir, CompactionType compa job.getJobName() + "' to " + job.getQueueName() + " queue. " + "(current delta dirs count=" + curDirNumber + ", obsolete delta dirs count=" + obsoleteDirNumber + ". TxnIdRange[" + minTxn + "," + maxTxn + "]"); - RunningJob rj = new JobClient(job).submitJob(job); + JobClient jc = new JobClient(job); + RunningJob rj = jc.submitJob(job); + try { + if (!jc.monitorAndPrintJob(job, rj)) { + throw new IOException("Job failed!"); + } + } catch (InterruptedException ie) { + Thread.currentThread().interrupt(); + } + LOG.info("Submitted compaction job '" + job.getJobName() + "' with jobID=" + rj.getID() + " compaction ID=" + id); txnHandler.setHadoopJobId(rj.getID().toString(), id); rj.waitForCompletion();