Исключение NullPointerException с saveAsTextFile

Я получаю NPE, когда пытаюсь объединиться и сохранить RDD.Код работает локально,а также работает на кластере в оболочке scala, но выдает ошибку при отправке ...

Могу ли я написать простой текстовый файл HDFS (или локальный) из программы Spark, а не из RDD?

У меня есть программа Spark (в Scala) и

Как использовать Scala и Python в одном проекте Spark?

Это возможно, чтобы трубаSpark RDD в Python?Потому что мне нужна библиотека Python для некоторых вычислений моих данных, но мой основной проект Spark основан...

В Scala, как я могу создать подкласс Java-класса с несколькими конструкторами?

Предположим, у меня есть класс Java с несколькими конструкторами:

Spark Streaming на EC2: Исключение в потоке «основной» java.lang.ExceptionInInitializerError

Я пытаюсь запустить spark-submit для файла JAR, который я создал. Когда я запускаю его локально на моей машине, он работает правильно, но при развертывании н...

Spark извлекает значения из строки

У меня есть следующий датафрейм

Преобразование RDD [org.apache.spark.sql.Row] в RDD [org.apache.spark.mllib.linalg.Vector]

Двойное определение Scala (2 метода имеют стирание одного типа)

Я написал это в Scala, и он не будет компилироваться:

Play framework и Slick автоматическое создание базы данных

Я использую play 2.4 и Slick 3, можно ли автоматически генерировать ddl-скрипты, это эволюции?В официальных документах я нашел несколько сценариев, но где мн...

Может ли SBT опубликовать в артефакте JFrog

Моя организация использует артефакт JFROG для раздачи всех банок.До сих пор я всегда использовал SBT для разработки Scala. Но теперь, когда я ищу способы опу...