File tree Expand file tree Collapse file tree
sql/hive/src/main/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -24,6 +24,7 @@ import java.rmi.server.UID
2424import scala .collection .JavaConverters ._
2525import scala .language .implicitConversions
2626import scala .reflect .{classTag , ClassTag }
27+ import scala .util .control .NonFatal
2728
2829import com .google .common .base .Objects
2930import org .apache .avro .Schema
@@ -120,8 +121,12 @@ private[hive] object HiveShim extends Logging {
120121 private def hasInheritanceOf [UDFType : ClassTag ](funcName : String , clazz : Class [_]): Boolean = {
121122 val clsTag = classTag[UDFType ].runtimeClass
122123 if (isSubClassOf(clazz, clsTag)) {
123- val funcClass = clazz.getMethod(funcName, classOf [MapredContext ])
124- funcClass.getDeclaringClass != clsTag
124+ try {
125+ val funcClass = clazz.getMethod(funcName, classOf [MapredContext ])
126+ funcClass.getDeclaringClass != clsTag
127+ } catch {
128+ case NonFatal (_) => false
129+ }
125130 } else {
126131 false
127132 }
You can’t perform that action at this time.
0 commit comments