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..75941b3f33 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 @@ -394,7 +394,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);