flume

0зной

1ответ

Канал памяти дыма потребляет дисковое пространство

Я запускаю агент flume, который использует канал памяти. agent.channels.c1.type = memory agent.channels.c1.capacity = 1000000 Источник имеет тип syslogtcp и утонуть, если типа hdfs. Агент собирает

0зной

1ответ

Невозможно записать с удаленного HDFS с использованием флюма

Я пытаюсь записать текст в HDFS удаленной машины, используя лоток. Но мои попытки потерпели неудачу. Я использую cloudera quickstart VM в качестве удаленной машины. Вот мои шаги: Я запускаемые желоб к

0зной

1ответ

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

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

0зной

1ответ

Соединение не установлено

У меня есть два беговых контейнера для дымохода и хаоса. Пусть это будет hadoop2 и flume2. Я создал эти два контейнера из двух изображений: hadoop_alone и flume_alone. docker run -d -p 10.236.173.XX:8

0зной

1ответ

настройки крена Flume не работает

Edit *: Вот полный конфигурационный файл: tier1.sources = source1 tier1.channels = channel1 tier1.sinks = sink1 tier1.sources.source1.type = org.apache.flume.source.kafka.KafkaSource tier1.sources

1зной

2ответ

Flume Источник HDFS

Я хочу использовать flume для переноса данных из каталога hdfs в каталог также в hdfs, в этой передаче я хочу применить обработку морфина. Например: мой источник "hdfs://localhost:8020/user/flume/data