Hello Apache team, I am new to hadoop flume environment and I am currently working on flume. I am getting an error. Below, I have posted my config file and also log error that I am facing. Please guide me with my bug. Thanks in advance for your help.
*flume.config.file* # Please paste flume.conf here. Example: # Sources, channels, and sinks are defined per # agent name, in this case 'pnm'. pnm.sources = SPOOL pnm.channels = MemChannel pnm.sinks = AVRO # For each source, channel, and sink, set # standard properties. pnm.sources.SPOOL.type = spooldir pnm.sources.SPOOL.spoolDir = /home/s_sdldalplhdxxxedh/pnm-poll-results pnm.sources.SPOOL.channels = MemChannel MemChannel2 pnm.sources.SPOOL.fileHeader = true pnm.sources.SPOOL.deletePolicy = immediate pnm.sources.SPOOL.consumeOrder = oldest pnm.sources.SPOOL.batchSize = 1 pnm.sources.SPOOL.interceptors = time pnm.sources.SPOOL.interceptors.time.type = org.apache.flume.interceptor.TimestampInterceptor$Builder pnm.sources.SPOOL.deserializer = com.suddenlink.flume.WholeFileDeserializer$Builder pnm.sinks.AVRO.type = avro pnm.sinks.AVRO.channel = MemChannel pnm.sinks.AVRO.hostname = sdldalplhdw01.suddenlink.cequel3.com pnm.sinks.AVRO.port = 40001 pnm.sinks.AVRO.batchSize = 1 # Other properties are specific to each type of # source, channel, or sink. In this case, we # specify the capacity of the memory channel. pnm.channels.MemChannel.capacity = 1000000 pnm.channels.MemChannel.type = memory *Log Error* 7:30:45.575 PMERRORorg.apache.flume.SinkRunner Unable to deliver event. Exception follows. org.apache.flume.EventDeliveryException: Failed to send events at org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:392) 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:745) Caused by: org.apache.flume.EventDeliveryException: NettyAvroRpcClient { host: sdldalplhdw01.suddenlink.cequel3.com, port: 40001 }: Failed to send batch at org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:315) at org.apache.flume.sink.AbstractRpcSink.process(AbstractRpcSink.java:376) ... 3 more Caused by: org.apache.flume.EventDeliveryException: NettyAvroRpcClient { host: sdldalplhdw01.suddenlink.cequel3.com, port: 40001 }: Handshake timed out after 20000ms at org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:359) at org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:303) ... 4 more Caused by: java.util.concurrent.TimeoutException at java.util.concurrent.FutureTask.get(FutureTask.java:201) at org.apache.flume.api.NettyAvroRpcClient.appendBatch(NettyAvroRpcClient.java:357) ... 5 more Regards, Nikhil Illinois, USA.