You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/11/27 04:36:59 UTC
spark git commit: Fix style violation for b63938a8b04
Repository: spark
Updated Branches:
refs/heads/master 5eaed4e45 -> 10e315c28
Fix style violation for b63938a8b04
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/10e315c2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/10e315c2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/10e315c2
Branch: refs/heads/master
Commit: 10e315c28c933b967674ae51e1b2f24160c2e8a5
Parents: 5eaed4e
Author: Reynold Xin <rx...@databricks.com>
Authored: Thu Nov 26 19:36:43 2015 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Thu Nov 26 19:36:43 2015 -0800
----------------------------------------------------------------------
.../apache/spark/sql/execution/datasources/jdbc/JDBCRDD.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/10e315c2/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 f9b7259..57a8a04 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
@@ -20,6 +20,8 @@ package org.apache.spark.sql.execution.datasources.jdbc
import java.sql.{Connection, DriverManager, ResultSet, ResultSetMetaData, SQLException}
import java.util.Properties
+import scala.util.control.NonFatal
+
import org.apache.commons.lang3.StringUtils
import org.apache.spark.rdd.RDD
@@ -498,7 +500,7 @@ private[sql] class JDBCRDD(
try {
conn.commit()
} catch {
- case e: Throwable => logWarning("Exception committing transaction", e)
+ case NonFatal(e) => logWarning("Exception committing transaction", e)
}
}
conn.close()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org