ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java index eb66c31..d7fd9da 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java @@ -63,7 +63,7 @@ public HiveLockObjectData(String queryId, String lockTime, String lockMode, Stri this.lockTime = StringInternUtils.internIfNotNull(removeDelimiter(lockTime)); this.lockMode = removeDelimiter(lockMode); this.queryStr = StringInternUtils.internIfNotNull( - queryStr == null ? null : StringUtils.substring(removeDelimiter(queryStr.trim()), 0, + queryStr == null ? null : StringUtils.abbreviate(removeDelimiter(queryStr.trim()), conf.getIntVar(HiveConf.ConfVars.HIVE_LOCK_QUERY_STRING_MAX_LENGTH))); }