diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala index 5b0c94531bd0a..4409832da0613 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/jdbc/JDBCOptions.scala @@ -192,7 +192,7 @@ class JDBCOptions( parameters.get(JDBC_CONNECTION_FACTORY_PROVIDER).map { className => try { Utils.classForName(className).newInstance.asInstanceOf[ConnectionFactoryProvider] } catch { - case _ => + case _ : Throwable => throw new IllegalArgumentException(s"$className is not a valid ConnectionFactoryProvider") } }.getOrElse(DefaultConnectionFactoryProvider)