Re: Hadoop 2x Compatability

2014-08-30 Thread Chris Horrocks
Thanks Sandeep & Hari your help is much appreciated. I kept having build errors on the TestAsyncHBaseSink test but rather than ignoring them I tried the 1.5.0.1 binaries which worked perfectly first time. On Fri, Aug 29, 2014 at 7:23 PM, Hari Shreedharan wrote: > How are you using Flume? If yo

Re: Flume/Avro schema manipulation

2014-08-30 Thread Javi Roman
It could be useful for you this project [1] the side where the source is converted to avro using a custom parser. [1] https://github.com/danieltardon/flume-ng-kafka-avro-sink On Fri, Aug 29, 2014 at 5:18 PM, Ed Judge wrote: > From initial reading of what it does, it look promising. So, I could

Flume ELS sink - indexname and indextype

2014-08-30 Thread Jean
Hello Is it possible for the elasticsearch sink ?: Have the option to disable the suffix appended, ie -MM-DD Have dynamic indexname derived from a avro header Have dynamic indextype also like above Thx Jean