Я получаю эту ошибку при использовании искры:
Py4JError: Произошла ошибка при вызове o25.isBarrier. Трассировка:
py4j.Py4JException: метод isBarrier ([]) не существует
Проверка версии и настройка конфигурации перепроверены
from pyspark import SparkContext
from pyspark.sql.session import SparkSession
sc = SparkContext()
spark = SparkSession(sc)
filepath = "D:\\DataScienceIntProgram\\spark\\a.us.csv"
us_stock = sc.textFile(filepath)
us_stock.take(10)
Py4JError: Произошла ошибка при вызове o25.isBarrier. Трассировка:
py4j.Py4JException: метод isBarrier ([]) не существует