error org apache flume sink hdfs HDFSEventSink process HDFSEventSink java 456 HDFS IO error java io IOException

Question

I'm trying to run flume with an hdfs sink. But when I run flume and send events to it I got the following error.

[WARN - org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:456)] HDFS IO error
java.io.IOException: Callable timed out after 5000 ms
    at org.apache.flume.sink.hdfs.HDFSEventSink.callWithTimeout(HDFSEventSink.java:352)
    at org.apache.flume.sink.hdfs.HDFSEventSink.append(HDFSEventSink.java:727)
    at org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:430)
    at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
    at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
    at java.lang.Thread.run(Thread.java:679)
Caused by: java.util.concurrent.TimeoutException
    at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:258)

How can I solve this error?
 

Answer 1

Hi@akhtar,

There may be problem in firewall, so make sure iptables is off.

$ iptables -F

If it will not work, then check the following properties in flume-conf.properties file.

agent.sinks.hdfs-sink.hdfs.path = hdfs://ip:9000/user/hdfs/flume
agent.sinks.hdfs-sink.hdfs.callTimeout = 180000

Set hdfs path and time accordingly your set up.