diff --git ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java index d7e01ee..c2aa597 100644 --- ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java +++ ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java @@ -40,10 +40,10 @@ public HiveLockObjectData(String queryId, String lockTime, String lockMode, String queryStr) { - this.queryId = queryId; - this.lockTime = lockTime; - this.lockMode = lockMode; - this.queryStr = queryStr.trim(); + this.queryId = removeDelimiter(queryId); + this.lockTime = removeDelimiter(lockTime); + this.lockMode = removeDelimiter(lockMode); + this.queryStr = removeDelimiter(queryStr.trim()); } @@ -203,4 +203,8 @@ public boolean equals(Object o) { data == null ? tgt.getData() == null : tgt.getData() != null && data.equals(tgt.getData()); } + + private static String removeDelimiter(String in) { + return in.replaceAll(":",""); + } }