diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala index f24834b938a1..8a248a251820 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionCatalog.scala @@ -126,7 +126,7 @@ private[sql] class HiveSessionCatalog( // Hive UDF/UDAF/UDTF with function definition. Otherwise, we just throw it earlier. case _: InvalidUDFClassException => makeHiveFunctionExpression(name, clazz, input) - case e => throw e + case NonFatal(e) => throw e } } }