diff options
| author | Vinod K C <vinod.kc@huawei.com> | 2015-04-23 12:00:23 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-04-23 12:00:23 -0700 |
| commit | c1213e6a92e126ad886d9804cedaf6db3618e602 (patch) | |
| tree | 7927cb327ab7172d02240aff70c7fb9271afbdef /sql | |
| parent | 534f2a43625fbf1a3a65d09550a19875cd1dce43 (diff) | |
| download | spark-c1213e6a92e126ad886d9804cedaf6db3618e602.tar.gz spark-c1213e6a92e126ad886d9804cedaf6db3618e602.tar.bz2 spark-c1213e6a92e126ad886d9804cedaf6db3618e602.zip | |
[SPARK-7055][SQL]Use correct ClassLoader for JDBC Driver in JDBCRDD.getConnector
Author: Vinod K C <vinod.kc@huawei.com>
Closes #5633 from vinodkc/use_correct_classloader_driverload and squashes the following commits:
73c5380 [Vinod K C] Use correct ClassLoader for JDBC Driver
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala index b975191d41..f326510042 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/jdbc/JDBCRDD.scala @@ -26,6 +26,7 @@ import org.apache.spark.rdd.RDD import org.apache.spark.sql.catalyst.expressions.{Row, SpecificMutableRow} import org.apache.spark.sql.types._ import org.apache.spark.sql.sources._ +import org.apache.spark.util.Utils private[sql] object JDBCRDD extends Logging { /** @@ -152,7 +153,7 @@ private[sql] object JDBCRDD extends Logging { def getConnector(driver: String, url: String, properties: Properties): () => Connection = { () => { try { - if (driver != null) Class.forName(driver) + if (driver != null) Utils.getContextOrSparkClassLoader.loadClass(driver) } catch { case e: ClassNotFoundException => { logWarning(s"Couldn't find class $driver", e); |