В этом RDD
отсутствует SparkContext
. Это может произойти в следующих случаях:
RDD
преобразования и действия НЕ запускаются драйвером
, но внутри других преобразований; например, rdd1.map(x => rdd2.values.count() * x)
является недопустимым, поскольку преобразование значений и действие count
не могут быть выполнены внутри преобразования rdd1.map