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
