diff --git ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java index a67db8e606..2cdea7d84f 100644 --- ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java +++ ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java @@ -17,6 +17,7 @@ */ package org.apache.hadoop.hive.ql.txn.compactor; +import com.esotericsoftware.minlog.Log; import com.google.common.annotations.VisibleForTesting; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @@ -394,7 +395,12 @@ protected Boolean findNextCompactionAndExecute(boolean computeStats) throws Inte long compactorTxnId = NOT_SET; try { if (msc == null) { - msc = HiveMetaStoreUtils.getHiveMetastoreClient(conf); + try { + msc = HiveMetaStoreUtils.getHiveMetastoreClient(conf); + } catch (Exception e) { + LOG.error("Failed to connect to HMS", e); + return false; + } } ci = CompactionInfo.optionalCompactionInfoStructToInfo(msc.findNextCompact(workerName)); LOG.debug("Processing compaction request " + ci);