diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala index a07ec165f3fcb..7637c3c7a3b96 100644 --- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala +++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala @@ -202,11 +202,12 @@ private[hive] class HiveClientImpl( private def getHive(conf: HiveConf): Hive = { try { - Hive.getWithoutRegisterFns(conf) + classOf[Hive].getMethod("getWithoutRegisterFns", classOf[HiveConf]) + .invoke(null, conf).asInstanceOf[Hive] } catch { // SPARK-37069: not all Hive versions have the above method (e.g., Hive 2.3.9 has it but // 2.3.8 don't), therefore here we fallback when encountering the exception. - case _: NoSuchMethodError => + case _: NoSuchMethodException => Hive.get(conf) } }