flume-ng

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

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

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

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