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

[dengzh]

This is an automated email from the ASF dual-hosted git repository.

dengzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new ca24aeb929f HIVE-29382 : Remove redundant logs generated by compaction 
worker thread (#6246)
ca24aeb929f is described below

commit ca24aeb929f5de4f96933cce0b277cf8329021de
Author: Vikram Ahuja <vikramahuja1...@users.noreply.github.com>
AuthorDate: Tue Dec 30 06:32:37 2025 +0530

    HIVE-29382 : Remove redundant logs generated by compaction worker thread 
(#6246)
---
 ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 c08da2b86e6..80c978fc569 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);
       }