Foro Formación Hadoop

 
 
Imagen de VICTOR RUANO ARCONADA
Error en Flume
de VICTOR RUANO ARCONADA - viernes, 8 de septiembre de 2017, 14:52
 

Hola,

Cuando realizo la prueba de Flume siguiendo los pasos del video, me sale el siguiente error.

 

2017-09-08 05:41:22,013 (pool-5-thread-1) [ERROR - org.apache.flume.source.SpoolDirectorySource$SpoolDirectoryRunnable.run(SpoolDirectorySource.java:269)] FATAL: Spool Directory source src1: { spoolDir: /home/cervantes/poesia }: Uncaught exception in SpoolDirectorySource thread. Restart or reconfigure Flume to continue processing.
java.nio.charset.MalformedInputException: Input length = 1
    at java.nio.charset.CoderResult.throwException(CoderResult.java:277)
    at org.apache.flume.serialization.ResettableFileInputStream.readChar(ResettableFileInputStream.java:306)
    at org.apache.flume.serialization.LineDeserializer.readLine(LineDeserializer.java:133)
    at org.apache.flume.serialization.LineDeserializer.readEvent(LineDeserializer.java:71)
    at org.apache.flume.serialization.LineDeserializer.readEvents(LineDeserializer.java:90)
    at org.apache.flume.client.avro.ReliableSpoolingFileEventReader.readEvents(ReliableSpoolingFileEventReader.java:303)
    at org.apache.flume.source.SpoolDirectorySource$SpoolDirectoryRunnable.run(SpoolDirectorySource.java:241)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:304)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:178)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

¿Alquien sabe a que es debido?

Muchas Gracias

 

 
Imagen de Admin Formación Hadoop
Re: Error en Flume
de Admin Formación Hadoop - lunes, 18 de septiembre de 2017, 09:10
 

Buenos días Victor,

 

Revisa el fichero de configuración la propiedad de spoolDir. ¿Existe la ruta que le has indicado?

Para poder ayudarte necesitaríamos que nos copies el fichero de configuración del agente de Flume.

Un saludo,