add null check for the exception cause

apache · Apr 28, 2021 · 5cfb3c2 · 5cfb3c2
1 parent 86d3bb5
commit 5cfb3c2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/objects/objects.scala
@@ -134,7 +134,8 @@ trait InvokeLike extends Expression with NonSQLExpression {
         method.invoke(obj, args: _*)
       } catch {
         // Re-throw the original exception.
-        case e: java.lang.reflect.InvocationTargetException => throw e.getCause
+        case e: java.lang.reflect.InvocationTargetException if e.getCause != null =>
+          throw e.getCause
       }
       val boxedClass = ScalaReflection.typeBoxedJavaMapping.get(dataType)
       if (boxedClass.isDefined) {