fix

apache · Jul 21, 2020 · b18437c · b18437c
1 parent e83194f
commit b18437c
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/command/functions.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/command/functions.scala
@@ -266,10 +266,9 @@ case class RefreshFunctionCommand(
       val func = catalog.getFunctionMetadata(identifier)
       catalog.registerFunction(func, true)
     } else {
-      // clear cached function, if not exists throw exception
-      if (!catalog.unregisterFunction(identifier)) {
-        throw new NoSuchFunctionException(identifier.database.get, identifier.funcName)
-      }
+      // clear cached function and throw exception
+      catalog.unregisterFunction(identifier)
+      throw new NoSuchFunctionException(identifier.database.get, identifier.funcName)
     }
 
     Seq.empty[Row]