Отлично! стратегия ограничителя сделала свое дело! :) Я также попробую использовать процессор MergeRecord и протестировать его. Спасибо за помощь @Shu

я есть поток ниже, настроенный для чтения данных JSON и преобразовать его в CSV с помощью процессора convertRecord. Тем не менее, выходной файл потока заполняется только одной записью(Я предполагаю только первую запись) вместо ...

Аутентификация сервера Spark History в кластере Kerberized

Искры на YARN тоже меньше использовались

права пользователя файла hadoop

У меня проблема с настройкой прав доступа к файлам hadoop в hortonworks и cloudera.Мое требование:

Как установить размер блока данных в Hadoop? Это преимущество, чтобы изменить это?

Если мы можем изменить размер блока данных в Hadoop, пожалуйста, дайте мне знать, как это сделать. Выгодно ли менять размер блока? Если да, то дайте мне знат...

Таблицы кустов не найдены при работе в режиме YARN-Cluster

У меня есть приложение Spark (версия 1.4.1) на HDP 2.3. Работает нормально при работе в режиме YARN-Client. Однако при запуске его в режиме YARN-Cluster прил...

Передача учетных данных HBase в oozie Java Action

Проблема в подключении кафки извне

Я использую hortonwork Sandbox для сервера kafka, пытаясь соединить kafka из затмения с помощью кода Java. Используйте эту конфигурацию для подключения к про...

HBase на Hortonworks HDP Sandbox: не удается получить главный адрес от ZooKeeper

Я скачал HDP 2.1 из hortonworks для виртуальной коробки. Я получил следующую ошибку при использовании оболочки Hbase в случае простой команды: create 't1...

Интеграция Hbase с Hive: зарегистрировать таблицу Hbase