apache-spark-sql

-1зной

1ответ

Пример потоковой передачи Zeppling twitter, неспособный

Когда вы следуете учебнику zeppelin для потоковой передачи твитов и запрашиваете их с помощью SparkSQL, я запутался в ошибке, где временная таблица «твитов» не найдена. Точный код используется и ссылк

1зной

1ответ

Как-распространять работу таким образом, чтобы не запускать из памяти

Я пытаюсь запустить несколько искровых рабочих мест, но обычно исполнители кончатся памяти: 17/02/06 19:12:02 WARN TaskSetManager: Lost task 10.0 in stage 476.3 (TID 133250, 10.0.0.10): ExecutorLostFa

1зной

1ответ

Исключение при работе с программой Spark, с контекстом SQL в Scala

Я пытаюсь запустить простую программу Спарк SCALA построен с Maven Ниже приведен исходный код: case class Person(name:String,age:Int) object parquetoperations { def main(args:Array[String]){

1зной

1ответ

как отличить все столбцы dataframe к строке

У меня смешанный тип данных. Я читаю этот файл данных из таблицы с улей, используя команду spark.sql('select a,b,c from table'). Некоторые столбцы являются int, bigint, double и другие являются строка

0зной

1ответ

Как выбрать один и тот же столбец, в который входит полное внешнее соединение?

Если у меня есть две таблицы Table A user_id type 123 tier1 124 tier2 Table B user_id sub_type 123 sub_tier1 125 sub_tier2 Я хочу full outer присоединиться к ним и стать user_id type sub

0зной

1ответ

Нет вкладки SQL в истории искры сервера для искры sql job

Я использую дистрибутив Cloudera 5.8.3, который построен с искрой 1.6.0. Я отправляю работу Spark через oozie (он представлен как действие java) Я вижу, что задание успешно завершено, а также можно на