remove unnecessary param

apache · Jul 14, 2020 · 711656d · 711656d
1 parent a956144
commit 711656d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala
@@ -1344,8 +1344,8 @@ class SessionCatalog(
   /**
    * Unregister a temporary or permanent function from a session-specific [[FunctionRegistry]]
    */
-  def unregisterFunction(name: FunctionIdentifier, ignoreIfNotExists: Boolean): Unit = {
-    if (!functionRegistry.dropFunction(name) && !ignoreIfNotExists) {
+  def unregisterFunction(name: FunctionIdentifier): Unit = {
+    if (!functionRegistry.dropFunction(name)) {
       throw new NoSuchFunctionException(
         formatDatabaseName(name.database.getOrElse(currentDb)), name.funcName)
     }

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
@@ -267,7 +267,7 @@ case class RefreshFunctionCommand(
       catalog.registerFunction(func, true)
     } else if (catalog.isRegisteredFunction(identifier)) {
       // clear cached function.
-      catalog.unregisterFunction(identifier, true)
+      catalog.unregisterFunction(identifier)
     } else {
       throw new NoSuchFunctionException(identifier.database.get, functionName)
     }