Я пытаюсь обновить файл .tmp с дополнительными событиями каждые 5 минут, мой источник работает медленно, и для получения файла размером 128 МБ в моем приемнике hdfs требуется 30 минут. Есть ли какое-либо свойство в приемнике hdfs flume, где я могу...

Я пытаюсь обработать некоторые ключевые слова Twitter с помощью MemChannel и HDFS . Но flume-ng не показывает дальнейшего прогресса после статуса HDFS started на консоли. Вот содержимое /etc/flume-ns/conf/flume-env.sh файла. #...

Когда я запускаю эту команду hduser@ubuntu:/usr/local/flume$ bin/flume-ng agent --conf ./conf/ -f conf/twitterflume-agent.conf -Dflume.root.logger=DEBUG,console -n TwitterAgent Flume запускается, но через некоторое время выдает мне...

Попытка получить твиты Apache Flume в HortonWorks. (Используя учебную точку) Flume настроен правильно. Вот flume.conf TwitterAgent.sources = Twitter TwitterAgent.channels = MemChannel TwitterAgent.sinks = HDFS...

Не могли бы вы предоставить мне шаги по настройке Flume для потоковой передачи данных Facebook. Мы успешно настроили Flume для извлечения данных из Twitter. Пожалуйста, взгляните на конфигурацию, которую мы создали для извлечения данных из...

Я использую flume для обработки данных из нескольких источников и храню их в HDFS, но я не мог понять, как фильтровать данные перед сохранением в HDFS.

Я работаю над HDP (Hortonworks) и пытаюсь собирать твиты через Flume и загружать сохраненные данные из Hive. Проблема в том, что select * from tweetsavro limit 1; работает, а select * from tweetsavro limit 2; не работает, потому что Failed...

В настоящее время я работаю над проектом больших данных для анализа настроений по актуальным темам в Твиттере. Я следовал руководству Cloudera и понял, как отправлять твиты в Hadoop через Flume....