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 c08da2b86e60..80c978fc5696 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 @@ -198,11 +198,11 @@ protected Boolean findNextCompactionAndExecute(boolean collectGenericStats, bool findNextCompactRequest.setWorkerVersion(runtimeVersion); findNextCompactRequest.setPoolName(this.getPoolName()); ci = CompactionInfo.optionalCompactionInfoStructToInfo(msc.findNextCompact(findNextCompactRequest)); - LOG.info("Processing compaction request {}", ci); - if (ci == null) { return false; } + + LOG.info("Processing compaction request {}", ci); if ((runtimeVersion == null && ci.initiatorVersion != null) || (runtimeVersion != null && !runtimeVersion.equals(ci.initiatorVersion))) { LOG.warn("Worker and Initiator versions do not match. Worker: v{}, Initiator: v{}", runtimeVersion, ci.initiatorVersion); }