Я пытаюсь настроить лоток и следую this link. Следующая команда работает для меня: flume-ng agent -n TwitterAgent -c conf -f /usr/lib/apache-flume-1.7.0-bin/conf/flume.conf
В результате я получил с
Я индексирую текстовый документ с использованием Flume, я не вижу никаких сообщений об ошибке или предупреждении, но данные не попадают на уровень Solr Log для обоих Solr и Flume. в TRACE, ВСЕ Flume v
Я пытаюсь передать данные в базу данных MySQL, используя APACHE KAFKA и FLUME. (Вот мой конфигурационный файл желоб) agent.sources=kafkaSrc
agent.channels=channel1
agent.sinks=jdbcSink
agent.chann
Я пытаюсь загрузить данные JSON в Hive через Hive Sink. Но он не со следующей ошибкой: WARN org.apache.hive.hcatalog.data.JsonSerDe: Error [java.io.IOException: Field name expected] parsing json text