Repository: sqoop Updated Branches: refs/heads/trunk 18f5b2a77 -> d902d2449
SQOOP-1329: JDBC connection to Oracle timeout after data import but before hive metadata import (Andrey Dmitriev via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/d902d244 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/d902d244 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/d902d244 Branch: refs/heads/trunk Commit: d902d2449f60584de58a101fd128626944d6cd53 Parents: 18f5b2a Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu May 29 18:36:29 2014 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu May 29 18:36:29 2014 -0700 ---------------------------------------------------------------------- src/java/org/apache/sqoop/manager/OracleManager.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/d902d244/src/java/org/apache/sqoop/manager/OracleManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/manager/OracleManager.java b/src/java/org/apache/sqoop/manager/OracleManager.java index 77b8ba3..32cb303 100644 --- a/src/java/org/apache/sqoop/manager/OracleManager.java +++ b/src/java/org/apache/sqoop/manager/OracleManager.java @@ -291,8 +291,13 @@ public class OracleManager String password = options.getPassword(); String connectStr = options.getConnectString(); + try { + connection = CACHE.getConnection(connectStr, username); + } catch (SQLException e) { + connection = null; + LOG.debug("Cached connecion has expired."); + } - connection = CACHE.getConnection(connectStr, username); if (null == connection) { // Couldn't pull one from the cache. Get a new one. LOG.debug("Creating a new connection for "
