We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e8d6f54 commit f98f50aCopy full SHA for f98f50a
python/pyspark/ml/util.py
@@ -40,7 +40,6 @@
40
from contextlib import contextmanager
41
42
from pyspark import since
43
-from pyspark.errors.exceptions.connect import SparkException
44
from pyspark.ml.common import inherit_doc
45
from pyspark.sql import SparkSession
46
from pyspark.sql.utils import is_remote
@@ -319,6 +318,8 @@ def remote_call() -> Any:
319
318
return deserialize(properties)
320
321
if is_remote() and "PYSPARK_NO_NAMESPACE_SHARE" not in os.environ:
+ from pyspark.errors.exceptions.connect import SparkException
322
+
323
try:
324
return remote_call()
325
except SparkException as e:
0 commit comments