flume-ng

0зной

1ответ

Как использовать flume для загрузки zip-файлов в hdfs sink

Я новичок в flume.My flume agent, имеющий источник в качестве http-сервера, откуда он получает zip-файлы (сжатые файлы xml) на регулярном интервале. Эти zip-файлы очень маленькие (менее 10 мб), и я хо

0зной

2ответ

Не удалось запустить Elasticsearch Sink

Я пытаюсь запустить мой поиск elasticsearch. Однако я получаю следующую ошибку и у меня заканчиваются идеи о том, как ее исправить. Любая помощь приветствуется. Здесь ошибка: 2015-02-10 11: 43: 31234

0зной

1ответ

Flume agent не останавливает повторную попытку для невосстановимой ошибки solr

Я использую Morphline Solr Sink для хранения информации в Solr. Проблема, с которой я сталкиваюсь, заключается в том, что flume agent никогда не перестает повторять неудавшиеся запросы, которые иногда

1зной

1ответ

Ошибка на выходе из источника в HBase

Я установил HBase и Flume используя Apache Cloudera. У меня есть агент flume, работающий на сервере linux, где работает текущий мастер HBase. Я пытаюсь написать от spooldir к HBase, но я получаю следу

0зной

1ответ

Почему файлы приложения не загружаются в MapReduce Job?

У меня есть лоток, который передает данные в HDFS-приемник (добавляется в тот же файл), который я мог бы «cat» и видеть его с HDFS. Однако задание MapReduce только собирает первую партию, которая была

0зной

1ответ

данные о потерях в лотерее при сборе данных в режиме онлайн hdfs

Я использовал flume-ng 1.5 версия для сбора журналов. В потоке данных есть два агента, и они находятся на двух хостах, соответственно. И данные отсылаются от агента1 к агенту2. компонент агентов заклю