From d8c61d648208cd7b8f7b37d3b615d895e7857771 Mon Sep 17 00:00:00 2001 From: luogankun Date: Wed, 14 Jan 2015 14:13:40 +0800 Subject: [PATCH] [SPARK-5239][CORE]JdbcRDD throws 'java.lang.AbstractMethodError: oracle.jdbc.driver.xxxxxx.isClosed()Z' --- core/src/main/scala/org/apache/spark/rdd/JdbcRDD.scala | 6 +++--- 1 file 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 642a12c1edf6..4fe7622bda00 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")