You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by de...@apache.org on 2025/12/30 01:02:44 UTC
(hive) branch master updated: HIVE-29382 : Remove redundant logs generated by compaction worker thread (#6246)
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 <vi...@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);
}