Я не хочу настраивать автономный кластер Flink, также не нужно конвертировать сеанс Flink для...

Я хочу запустить инструмент Java на данных, хранящихся в кластере Hadoop.Я пытаюсь сделать это,...

Я унаследовал неприятный фрагмент итеративного кода TSQL, который нужно запускать на спарк. Я не...

Я установил mapreduce.map.memory.mb 256 МБ и mapreduce.reduce.memory.mb 256 МБ в mapred-site.xml

Я работаю над процессом чтения из базы данных DB2 с использованием Spark и загрузки в другую цель -...

В одном из моих приложений я включил динамическое распределение с искровым потоком.Это работает...

Вот мой файл yarn-site.xml: <property> <name>yarn.nodemanager.aux-services</name>...

Я пытаюсь выяснить, почему моя папка spark .sparkStaging по умолчанию находится в / user / name /...

Я только что заметил, что мой Spark на YARN все работает на локальном компьютере, его рабочий...

При работе в автономном режиме рабочим каталогом обычно является $ SPARK_HOME / work. Однако я...

У меня запущено несколько заданий Sqoop для извлечения данных из источника данных Oracle.В идеале...

Первая попытка Mapreduce (убито) Время окончания, отображаемое в интерфейсе ResourceManager - «Пт...

Я установил spark.yarn.tags в своем искровом приложении, и это видно и в моей конфигурации при...

Причина: org.apache.thrift.transport.TTransportException: Простая аутентификация не удалась: Пряжа...

Я пытаюсь разработать интеграционное тестирование.Я буду запускать несколько jar-файлов, написанных...

Я внедряю систему, основанную на Hadoop 3.1.1 и YARN и состоящую из 2 виртуальных машин с...

Я написал следующий сценарий оболочки для настройки планировщика пряжи, но это не работает должным...

Улей= 8G " set spark.executor.memory = 32G" set hive.exec.reducers.bytes.per.reducer = 640000000 ";...

Вот снимок ошибки: [hduser@secondary ~]$ yarn jar test_word_count.jar com.test.wordc.WordCount...

Я запускаю пример Spark PI Job, используя команду spark-submit в режиме yarn-client.Моя работа...

Я настраиваю улей 3.1.0 для работы с hadoop 3.0.0.Эта ошибка возникает почти сразу, когда я...

У меня есть несколько файлов данных в моей папке Hortonworks HDFS.Мое требование - сбросить данные...

моя команда строит вычислительную платформу в реальном времени на основе Flink.Мы представляем...

У меня очень маленький кластер с 2 узлами Hadoop-HBase.Я выполняю MapReduce рабочих мест на нем.Я...

В основном я хочу развернуть пользовательский JAR-файл Flink в новом кластере AWS EMR.Вот краткое...