diff --git ql/src/java/org/apache/hadoop/hive/ql/Driver.java ql/src/java/org/apache/hadoop/hive/ql/Driver.java index 0b51d9d..9688249 100644 --- ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -408,7 +408,7 @@ public int compile(String command, boolean resetTaskIds) { saveSession(queryState); try { - command = new VariableSubstitution().substitute(conf,command); + command = new VariableSubstitution().substitute(conf,command).trim(); ctx = new Context(conf); ctx.setTryCount(getTryCount()); ctx.setCmd(command); 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..8013d44 100644 --- ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java +++ ql/src/java/org/apache/hadoop/hive/ql/lockmgr/HiveLockObject.java @@ -43,7 +43,7 @@ public HiveLockObjectData(String queryId, this.queryId = queryId; this.lockTime = lockTime; this.lockMode = lockMode; - this.queryStr = queryStr.trim(); + this.queryStr = queryStr; }