diff options
author | Sean Owen <sowen@cloudera.com> | 2015-02-10 09:19:01 +0000 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2015-02-10 09:19:01 +0000 |
commit | 2d1e916730492f5d61b97da6c483d3223ca44315 (patch) | |
tree | 81943a45f12b22595255e8e6d6e466998020df36 /core | |
parent | c15134632e74e3dee05eda20c6ef79915e15d02e (diff) | |
download | spark-2d1e916730492f5d61b97da6c483d3223ca44315.tar.gz spark-2d1e916730492f5d61b97da6c483d3223ca44315.tar.bz2 spark-2d1e916730492f5d61b97da6c483d3223ca44315.zip |
SPARK-5239 [CORE] JdbcRDD throws "java.lang.AbstractMethodError: oracle.jdbc.driver.xxxxxx.isClosed()Z"
This is a completion of https://github.com/apache/spark/pull/4033 which was withdrawn for some reason.
Author: Sean Owen <sowen@cloudera.com>
Closes #4470 from srowen/SPARK-5239.2 and squashes the following commits:
2398bde [Sean Owen] Avoid use of JDBC4-only isClosed()
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala b/core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala index 642a12c1ed..4fe7622bda 100644 --- a/core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala @@ -99,21 +99,21 @@ class JdbcRDD[T: ClassTag]( override def close() { try { - if (null != rs && ! rs.isClosed()) { + if (null != rs) { rs.close() } } catch { case e: Exception => logWarning("Exception closing resultset", e) } try { - if (null != stmt && ! stmt.isClosed()) { + if (null != stmt) { stmt.close() } } catch { case e: Exception => logWarning("Exception closing statement", e) } try { - if (null != conn && ! conn.isClosed()) { + if (null != conn) { conn.close() } logInfo("closed connection") |