У меня есть кластер Hadoop в AWS с YARN, на который я подаю искровые приложения.Я работаю через...

Я хочу изменить тип данных с String на TimeStamp в улье, но приведенные ниже запросы не помогают....

Я просматривал веб-сайт Hadoop и нашел следующую ссылку для потоковой передачи hadoop....

Как настроить разделение при повторном разбиении в Spark.Я ищу эквивалентную реализацию методов...

Я хочу решить проблему подсчета слов и хочу получить результаты в обратном порядке в зависимости от...

Я новичок в Hadoop и запускаю пример wordCount2.Однако я получаю ниже ошибка Exception in thread...

Когда мы получим класс X не может быть приведен к классу X какие-то исключения?Мы пытаемся написать...

Я присоединился к нескольким таблицам, и общее количество строк составляет около 25 миллиардов

Привет, я написал этот код ниже в scala spark, при запуске с 6,4 миллионами записей, я получаю эту...

Я недавно начал работать в среде Hadoop.Мне нужно было сделать несколько базовых ETL, чтобы...

Мне нужна помощь с диагностикой того, почему конкретное задание в Jobtracker является долгосрочным,...

Наше приложение имеет несколько загрузчиков классов.Это сделано для того, чтобы избежать конфликтов...

Я получил следующую ошибку: 2019-02-01 12:01:39 INFO YarnAllocator:54 - Driver requested a total...

У меня есть банка с искрой, в которой есть код, соединяющий базу данных оракула, улей и кассандру.Я...

У меня есть сценарий поиска дочерних узлов самого низкого уровня из таблицы иерархии, имеющих...

Когда я пытаюсь отправить файл json в эластичный поиск с помощью pyspark, он выдает ошибку. Вот мой...

Hadoop resource-manger не может подключиться к наменоде.Я развернул hadoop в Docker-контейнере с...

Мы экспериментируем с запуском Spark в нашем проекте без Hadoop и распределенного хранилища, такого...

Я копирую все файлы из одного кластера Hadoop в другой кластер Hadoop, используя distcp.С 1-й...

Я запускаю свое приложение на spark2.3.0 с зависимостями hadoop-* - 2.8.0, aws-java-sdk - 1.10.6,...

моя работа с искрой; val df = spark.sql(s"""""") df.write

у меня 4 кластера.Это работало хорошо, прежде чем я выключил сервер .. (Когда я выключил этот...

Я пытаюсь зациклить ту же модель R с 40 различными входами. Я запускаю это на EMR и пытаюсь...

У меня есть требование, когда мне нужно объединить несколько таблиц Hive в формате ORC и...

В нашем проекте мы используем искровой кластер Apache с открытым исходным кодом.Нужна помощь по...