flume-ng

1зной

1ответ

Я пытаюсь передать данные в базу данных MySQL, используя APACHE KAFKA и FLUME. (Вот мой конфигурационный файл желоб) agent.sources=kafkaSrc agent.channels=channel1 agent.sinks=jdbcSink agent.chann

0зной

1ответ

Flive Hive sink не удалось сериализовать JSON с массивом

Я пытаюсь загрузить данные JSON в Hive через Hive Sink. Но он не со следующей ошибкой: WARN org.apache.hive.hcatalog.data.JsonSerDe: Error [java.io.IOException: Field name expected] parsing json text

0зной

1ответ

Http-source flum в hdfs не работает.? Код состояния для почтового запроса 400?

Устанавливая http-источник для агента flume, я использовал порт 8989. и агент начинает нормально, но когда я делаю запрос на отправку, я получаю status_code 400 и на запрос request status_code 400. Кт

1зной

1ответ

Можно ли использовать WebHDFS с Flume?

Я хотел бы, чтобы flume агент сидел вне кластера hadoop и хотел бы знать, можно ли использовать лоток для отправки сообщений в кластер hadoop с помощью WebHDFS. Если нет, существуют ли альтернативы ис

0зной

1ответ

Включение совместного использования ресурсов кросс-исходного кода на Apache Flume

Я занимаюсь разработкой веб-страницы, которая в основном подключается к серверу Flume через порт 8080. Каждый раз, когда клиент отправляет новое ходатайство, он выдает 403 запретную ошибку, поскольку

0зной

1ответ

Флуд HDFS-приемник хранит только одну строку источника данных, используя источник netcat

Я пытаюсь загрузить данные в HDFS с использованием Flume 1.7. Я создал следующую конфигурацию: # Starting with: /opt/flume/bin/flume-ng agent -n Agent -c conf -f /opt/flume/conf/test.conf # Naming th

0зной

1ответ

Ingest bzip2 файлы с Apache Flume

Мне нужно глотать сжатые файлы в bzip2. Возможно ли использование лотка? Я пробовал это с помощью каталога буферизации и BlobDeserializer, но он не читается в раковине. Заранее благодарен!