flume-ng

2зной

2ответ

Flume - HiveSink: java.lang.NoClassDefFoundError: org/apache/hive/hcatalog/streaming/RecordWriter

Я пытаюсь создать раковину улья в моей конфигурации дымохода, и когда я запускаю flume-ng, я получаю некоторые проблемы с зависимостью, как показано ниже , Не могли бы вы рассказать мне, как я могу пр

1зной

1ответ

log4j2- ERROR Appenders содержит недопустимый элемент или атрибут «Flume»

Я пытаюсь использовать Flume Appender Properties log4j2. Но при запуске программы возникают следующие ошибки. 2016-01-20 16:36:42,436 main ERROR Appenders contains an invalid element or attribute "Flu

5зной

1ответ

Полезное пространство, израсходованное в лотке с использованием файлового канала

Я работаю над Flume с каталогом Spool в качестве источника, HDFS в качестве раковины и файла в качестве канала. При выполнении работы с ломом. Я становлюсь ниже вопроса. Канал памяти работает нормальн

3зной

1ответ

FLUME IllegalStateException: begin() вызывается, когда транзакция открыта

Я написал пользовательскую флягу, названную MySink, чей технологический метод указан в первом фрагменте ниже. Я получаю IllegalStateException следующим образом (трассировка стека доступен во 2-й фрагм

0зной

1ответ

Maven Не удалось передать артефакт с/на repo1.maven.org

Я пытаюсь построить Apache Flume, используя mvn install -DskipTests на SLES12. Сообщение об ошибке идет: [ERROR] Не удалось выполнить задачу по проекту водопропускной-нг-elasticsearch радиатора: Не уд

0зной

2ответ

Как получить доступ к папке на удаленном хосте, как испортить путь к каталогу в лотке

Вот мой файл FlumeHadoop.conf. a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = spooldir a1.sources.r1.channels = c1 a1.sources.r1.spoolDir =

0зной

2ответ

Flume: Маршрутизация событий на соответствующий раздел раздела с каналом Кафка

В Flume, используя канал Kafka, есть способ влиять на какой раздел отправляется событие? С Кафки раковине, то FlumeEvent заголовок key по-видимому, используется для выбора раздела, но я не мог найти к

0зной

1ответ

Ошибка HDFS IO org.apache.hadoop.ipc.RemoteException: сервер IPC версии 9 не может взаимодействовать с клиентской версией 4 i

Я использую Flume 1.6.0 на виртуальной машине и Hadoop 2.7.1 на другой виртуальной машине. Когда я отправляю Avro Events в Flume 1.6.0, и он пытается писать на Hadoop 2.7.1 HDFS System. Follwing проис