HIVE-29382 : Remove redundant logs generated by compaction worker thread (#6246)

vikramahuja1001 · web-flow · commit ca24aeb929f5 · 2025-12-30T09:02:37.000+08:00
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
@@ -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);
       }

Original file line number	Diff line number	Diff line change
`@@ -198,11 +198,11 @@ protected Boolean findNextCompactionAndExecute(boolean collectGenericStats, bool`
`198`	`198`	`findNextCompactRequest.setWorkerVersion(runtimeVersion);`
`199`	`199`	`findNextCompactRequest.setPoolName(this.getPoolName());`
`200`	`200`	`ci = CompactionInfo.optionalCompactionInfoStructToInfo(msc.findNextCompact(findNextCompactRequest));`
`201`		`- LOG.info("Processing compaction request {}", ci);`
`202`		`-`
`203`	`201`	`if (ci == null) {`
`204`	`202`	`return false;`
`205`	`203`	`}`
	`204`	`+`
	`205`	`+ LOG.info("Processing compaction request {}", ci);`
`206`	`206`	`if ((runtimeVersion == null && ci.initiatorVersion != null) \|\| (runtimeVersion != null && !runtimeVersion.equals(ci.initiatorVersion))) {`
`207`	`207`	`LOG.warn("Worker and Initiator versions do not match. Worker: v{}, Initiator: v{}", runtimeVersion, ci.initiatorVersion);`
`208`	`208`	`}`