You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pv...@apache.org on 2021/12/12 20:27:44 UTC
[hive] branch master updated: HIVE-25764: Add reason for the compaction failure message (Peter Vary reviewed by Denys Kuzmenko) (#2836)
This is an automated email from the ASF dual-hosted git repository.
pvary 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 bc9cb14 HIVE-25764: Add reason for the compaction failure message (Peter Vary reviewed by Denys Kuzmenko) (#2836)
bc9cb14 is described below
commit bc9cb14cf6e38b18022ccda0dd1f812d93e383a9
Author: pvary <pv...@cloudera.com>
AuthorDate: Sun Dec 12 21:27:32 2021 +0100
HIVE-25764: Add reason for the compaction failure message (Peter Vary reviewed by Denys Kuzmenko) (#2836)
---
ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/Worker.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 bcd4833..a90e307 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
@@ -722,7 +722,8 @@ public class Worker extends RemoteCompactorThread implements MetaStoreThread {
LockRequest lockRequest = createLockRequest(ci, txnId);
LockResponse res = msc.lock(lockRequest);
if (res.getState() != LockState.ACQUIRED) {
- throw new TException("Unable to acquire lock(S) on " + ci.getFullPartitionName());
+ throw new TException("Unable to acquire lock(s) on {" + ci.getFullPartitionName()
+ + "}, status {" + res.getState() + "}, reason {" + res.getErrorMessage() + "}");
}
lockId = res.getLockid();