Может кто-нибудь помочь исправить следующий код, пожалуйста?
import pyspark
from pyspark import SparkContext, SparkConf
conf = SparkConf()
conf.setMaster('yarn-cluster')
conf.setAppName('test')
sc = SparkContext.getOrCreate()
r = sc.textFile("data.csv")
r.collect()
Выдает ошибку со следующим исключением:
WARN cluster.YarnScheduler: начальное задание не принято
Ресурсы; проверьте интерфейс вашего кластера, чтобы убедиться, что работники зарегистрированы
и иметь достаточные ресурсы
Я ожидаю, что результат сбора будет распечатан.
Спасибо.