flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vikram Kulkarni <vikulka...@expedia.com>
Subject Custom Sink
Date Mon, 11 Mar 2013 03:52:46 GMT
I am trying to write a custom sink for flume-ng. I looked at the existing sinks and documentation
and coded it up. However, the 'process()' method that's supposed to receive the events always
ends up with a null event. I am doing Event event = channel.take(); but the event is null.
I see in the logs that this method is called repeatedly as the event is still in the channel
so I think it is reaching the sink but unable to take it out of the channel.

Can someone point me in the right direction?



View raw message