Foro Formación Hadoop

Error en Flume

 
Picture of VICTOR RUANO ARCONADA
Error en Flume
by VICTOR RUANO ARCONADA - Friday, 8 September 2017, 2:52 PM
 

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

 

Picture of Admin Formación Hadoop
Re: Error en Flume
by Admin Formación Hadoop - Monday, 18 September 2017, 9:10 AM
 

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,