apache-spark

1зной

1ответ

Импорт проекта scala sbt в Scala IDE сборка Eclipse SDK

Я загрузил проект github, который имеет искровый код scala и строит его с помощью sbt. Я пытаюсь импортировать проект в версию Scala IDE ниже версии. Но я не вижу возможности импортировать проект sbt

2зной

2ответ

Почему функция map sc.cassandraTable («test», «users»). Select («username») не может работать?

После spark-cassandra-connector's demo и Installing the Cassandra/Spark OSS Stack, под свечой скорлупе, я попытался следующий фрагмент кода: sc.stop val conf = new SparkConf(true) .set("spark.c

0зной

1ответ

zeppelin with spark 1.5.2 автономная ошибка кластера

Я загрузил двоичный код Zeppelin 0.5.5 в экземпляр redhat 6.3. Я также успешно создал искру 1.5.2. Теперь я хотел бы, чтобы zeppelin использовал эту искровую версию вместо предварительно скомпилирован

0зной

1ответ

Batch Insert In Cassandra с использованием Apache Spark висит и контекст не закрывается при запуске из Web Ser

Я новый, чтобы искра. Я пытаюсь вставить файлы csv в таблицу cassandra с помощью разъема spark-cassandra, как показано ниже: Файлы находятся в Hdf, и я получаю Пути всех файлов и для каждого пути, кот

0зной

1ответ

Как включить отказоустойчивость на основе линейки для интеграции Spark-Tachyon?

Я пытаюсь реализовать совместное использование RDD/Dataframe с помощью Tachyon. Насколько я понимаю, с HDFS underFS записи являются асинхронными (с репликацией на HDFS, происходящим за сценой) и, след

2зной

1ответ

Как подать заявку через REST API?

Я использую Datastax Enterprise 4.8.3. Я пытаюсь реализовать приложение на основе кварца, чтобы удаленно отправлять задания Spark. В ходе моих исследований я наткнулся на следующие ссылки: Apache Spar

0зной

1ответ

Spark не обнаруживает все ядра ЦП

У меня есть кластер, работающий Spark с 4 серверами, каждый из которых имеет 8 ядер. Как-то мастер не обнаруживает все доступные ядра. Он использует 18 из 32 ядер: Я ничего, относящееся к не не устано

0зной

1ответ

Как определить максимальный объем кэширования памяти во время работы Spark?

Может ли кто-нибудь сказать мне, как определить максимальный объем кэширования памяти во время работы Spark? Мне нужно это, чтобы показать производительность (использование памяти) моего алгоритма для