flume-ng

5calore

4risposta

non riesco a caricare log4j2 mentre eseguo fatjar

sto lavorando su un progetto in cui utilizzo log4j2 logging. durante lo sviluppo in intellij, tutto funziona correttamente e la registrazione viene eseguita come previsto. log4j2.xml è collegato trami

7calore

1risposta

File di testo Avro generato da Flume L'agente Twitter non viene letto in Java

Non è possibile leggere e analizzare il file creato dallo streaming dei dati di Twitter tramite l'agente Flume di Twitter, né utilizzando Java né Avro Tools. Il mio requisito è quello di convertire il

6calore

3risposta

Come inserire JSON in HDFS utilizzando Flume correttamente

Sto usando il HTTPSource in Flume per ricevere POST eventi in formato json come segue: {"username":"xyz","password":"123"} La mia domanda è: Devo modificare la fonte di gli eventi (intendo quella ch

5calore

1risposta

Flusso che non elabora le parole chiave dalla fonte Twitter con flume-ng con Hadoop 2.5 cdh5.3

Sto tentando di elaborare alcune parole chiave twitter con MemChannel e HDFS. Ma flume-ng non mostra ulteriori progressi dopo lo stato HDFS started sulla console. Qui ci sono i contenuti del file /etc

5calore

1risposta

Flume HDFS affondare: Rimuovere timestamp dal nome del file

Ho configurato agente canale artificiale per la mia domanda, in cui origine è Spooldir e lavandino è HDFS sono in grado di raccogliere i file in HDFS. configurazione dell'agente è: agent.sources = src

5calore

1risposta

Spazio utilizzabile esaurito nel canale utilizzando il canale file

Sto lavorando su Flume con Directory di spool come sorgente, HDFS come sink e File come canale. Quando si esegue il lavoro flume. Sto ricevendo sotto il problema. Il canale di memoria funziona corrett