fix python

apache · Feb 13, 2016 · c268740 · c268740
1 parent 8698275
commit c268740
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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