aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSean Owen <sowen@cloudera.com>2016-10-26 14:19:40 +0200
committerSean Owen <sowen@cloudera.com>2016-10-26 14:19:40 +0200
commit6c7d094ec4d45a05c1ec8a418e507e45f5a88b7d (patch)
treea3fd06467922ae4bdc66c999f4abaa9374660c81
parent93b8ad184aa3634f340d43a8bdf99836ef3d4f6c (diff)
downloadspark-6c7d094ec4d45a05c1ec8a418e507e45f5a88b7d.tar.gz
spark-6c7d094ec4d45a05c1ec8a418e507e45f5a88b7d.tar.bz2
spark-6c7d094ec4d45a05c1ec8a418e507e45f5a88b7d.zip
[SPARK-18022][SQL] java.lang.NullPointerException instead of real exception when saving DF to MySQL
## What changes were proposed in this pull request? On null next exception in JDBC, don't init it as cause or suppressed ## How was this patch tested? Existing tests Author: Sean Owen <sowen@cloudera.com> Closes #15599 from srowen/SPARK-18022.
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala
index e32db73bd6..41edb6511c 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JdbcUtils.scala
@@ -607,7 +607,7 @@ object JdbcUtils extends Logging {
} catch {
case e: SQLException =>
val cause = e.getNextException
- if (e.getCause != cause) {
+ if (cause != null && e.getCause != cause) {
if (e.getCause == null) {
e.initCause(cause)
} else {