You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2015/12/06 17:27:46 UTC

spark git commit: [SPARK-12048][SQL] Prevent to close JDBC resources twice

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


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

Author: gcc <sp...@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 <sp...@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org