Author: hashutosh
Date: Tue Mar 25 17:20:44 2014
New Revision: 1581423
URL: http://svn.apache.org/r1581423
Log:
HIVE-6646 : Error in txn handler SQL (Alan Gates via Ashutosh Chauhan)
Modified:
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java
Modified:
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java
URL:
http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java?rev=1581423&r1=1581422&r2=1581423&view=diff
==============================================================================
---
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java
(original)
+++
hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java
Tue Mar 25 17:20:44 2014
@@ -205,7 +205,7 @@ public class TxnHandler {
Statement stmt = dbConn.createStatement();
LOG.debug("Going to execute query <select ntxn_next from NEXT_TXN_ID " +
- "for update>");
+ " for update>");
ResultSet rs =
stmt.executeQuery("select ntxn_next from NEXT_TXN_ID for update");
if (!rs.next()) {
@@ -806,7 +806,7 @@ public class TxnHandler {
if (txnid > 0) {
// We need to check whether this transaction is valid and open
String s = "select txn_state from TXNS where txn_id = " +
- txnid + "for update";
+ txnid + " for update";
LOG.debug("Going to execute query <" + s + ">");
ResultSet rs = stmt.executeQuery(s);
if (!rs.next()) {
@@ -1157,7 +1157,7 @@ public class TxnHandler {
long now = System.currentTimeMillis();
// We need to check whether this transaction is valid and open
String s = "select txn_state from TXNS where txn_id = " +
- txnid + "for update";
+ txnid + " for update";
LOG.debug("Going to execute query <" + s + ">");
ResultSet rs = stmt.executeQuery(s);
if (!rs.next()) {
