From 04b6799932707f0a4aa4da0f2fc838bdb29794ce Mon Sep 17 00:00:00 2001
From: gcc <spark-src@condor.rhaag.ip>
Date: Sun, 6 Dec 2015 16:27:40 +0000
Subject: [PATCH] [SPARK-12048][SQL] Prevent to close JDBC resources twice
Author: gcc <spark-src@condor.rhaag.ip>
Closes #10101 from rh99/master.
---
.../apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala | 1 +
1 file changed, 1 insertion(+)
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 b9dd7f6b40..1c348ed62f 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 = {
--
GitLab