fix wrong use of sparkSession vs sparkContext

mspass-team · Jan 9, 2025 · 3f2d358 · 3f2d358
1 parent 5bc6e32
commit 3f2d358
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/mspasspy/client.py b/python/mspasspy/client.py
@@ -195,7 +195,7 @@ def __init__(
                     .master(self._spark_master_url)
                     .getOrCreate()
                 )
-                spark.parallelize([1, 2, 3, 4, 5]).collect()
+                spark.sparkContext.parallelize([1, 2, 3, 4, 5]).collect()
                 self._spark_context = spark.sparkContext
             except Exception as err:
                 raise MsPASSError(