You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2015/09/25 20:42:33 UTC
[23/25] hive git commit: HIVE-11939: TxnDbUtil should turn off jdbc
auto commit (Jimmy, reviewed by Alan)
HIVE-11939: TxnDbUtil should turn off jdbc auto commit (Jimmy, reviewed by Alan)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/1c0a314b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/1c0a314b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/1c0a314b
Branch: refs/heads/llap
Commit: 1c0a314be99cdd300c836fa80803f885b4954fca
Parents: 3eefcb5
Author: Jimmy Xiang <jx...@cloudera.com>
Authored: Wed Sep 23 13:41:49 2015 -0700
Committer: Jimmy Xiang <jx...@cloudera.com>
Committed: Fri Sep 25 08:04:11 2015 -0700
----------------------------------------------------------------------
.../src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/1c0a314b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java
index 37808ce..c465c84 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/TxnDbUtil.java
@@ -229,7 +229,9 @@ public final class TxnDbUtil {
ShimLoader.getHadoopShims().getPassword(conf, HiveConf.ConfVars.METASTOREPWD.varname);
prop.setProperty("user", user);
prop.setProperty("password", passwd);
- return driver.connect(driverUrl, prop);
+ Connection conn = driver.connect(driverUrl, prop);
+ conn.setAutoCommit(false);
+ return conn;
}
private static void closeResources(Connection conn, Statement stmt, ResultSet rs) {