diff --git a/python/pyspark/sql/functions.py b/python/pyspark/sql/functions.py
index d5bc1be36b01b..5fc1cc2cae10a 100644
--- a/python/pyspark/sql/functions.py
+++ b/python/pyspark/sql/functions.py
@@ -1652,7 +1652,7 @@ def _create_judf(self, name):
         jdt = ctx._ssql_ctx.parseDataType(self.returnType.json())
         if name is None:
             name = f.__name__ if hasattr(f, '__name__') else f.__class__.__name__
-        judf = sc._jvm.execution.python.UserDefinedPythonFunction(
+        judf = sc._jvm.org.apache.spark.sql.execution.python.UserDefinedPythonFunction(
             name, bytearray(pickled_command), env, includes, sc.pythonExec, sc.pythonVer,
             broadcast_vars, sc._javaAccumulator, jdt)
         return judf