Repository: spark
Updated Branches:
  refs/heads/master b6e8e63a0 -> 04b679993


[SPARK-12048][SQL] Prevent to close JDBC resources twice

Author: gcc <spark-...@condor.rhaag.ip>

Closes #10101 from rh99/master.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/04b67999
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/04b67999
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/04b67999

Branch: refs/heads/master
Commit: 04b6799932707f0a4aa4da0f2fc838bdb29794ce
Parents: b6e8e63
Author: gcc <spark-...@condor.rhaag.ip>
Authored: Sun Dec 6 16:27:40 2015 +0000
Committer: Sean Owen <so...@cloudera.com>
Committed: Sun Dec 6 16:27:40 2015 +0000

----------------------------------------------------------------------
 .../org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/04b67999/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
----------------------------------------------------------------------
diff --git 
a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
 
b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
index b9dd7f6..1c348ed 100644
--- 
a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
+++ 
b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala
@@ -511,6 +511,7 @@ private[sql] class JDBCRDD(
       } catch {
         case e: Exception => logWarning("Exception closing connection", e)
       }
+      closed = true
     }
 
     override def hasNext: Boolean = {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org

Reply via email to