Skip to content

Commit 9f93ea7

Browse files
author
Joseph Batchik
committed
fixed error with orc data source
1 parent 87b7f1c commit 9f93ea7

File tree

1 file changed

+7
-7
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/datasources

1 file changed

+7
-7
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ddl.scala

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -203,18 +203,18 @@ private[sql] object ResolvedDataSource extends Logging {
203203
private def tryLoad(provider: String): Option[Class[_]] = try {
204204
Some(loader.loadClass(provider))
205205
} catch {
206-
case cnf: ClassNotFoundException => if (provider.startsWith("org.apache.spark.sql.hive.orc")) {
207-
sys.error("The ORC data source must be used with Hive support enabled.")
208-
} else {
209-
None
210-
}
206+
case cnf: ClassNotFoundException => None
211207
}
212208

213209
/** Given a provider name, look up the data source class definition. */
214210
def lookupDataSource(provider: String): Class[_] = {
215211
serviceLoader.iterator().filter(_.format() == provider).toList match {
216-
case Nil => tryLoad(provider).orElse(tryLoad(s"$provider.DefaultSource"))
217-
.getOrElse(sys.error(s"Failed to load class for data source: $provider"))
212+
case Nil => tryLoad(provider).orElse(tryLoad(s"$provider.DefaultSource")).getOrElse(
213+
if (provider.startsWith("org.apache.spark.sql.hive.orc")) {
214+
sys.error("The ORC data source must be used with Hive support enabled.")
215+
} else {
216+
sys.error(s"Failed to load class for data source: $provider")
217+
})
218218
case head :: Nil => head.getClass
219219
case sources => sys.error(s"Multiple sources found for $provider, " +
220220
s"(${sources.map(_.getClass.getName).mkString(", ")}), " +

0 commit comments

Comments
 (0)