Hi Alex, I'm sorry that you found that class commented. I think so far nobody was interested in using the Flume source.It was commented out during a refactoring of the stream sources: https://github.com/apache/flink/pull/659#discussion-diff-29854032. I just looked a bit through the (commented) code, and it seems that the FlumeSource is at most an example for building a custom source.
Implementing a custom source is quite simple in Flink. Maybe you can get the job done easily by implementing a Flume source yourself. I also volunteer to review your code and help you if you need assistance. Regards, Robert On Wed, Jan 27, 2016 at 9:18 PM, Alexandr Dzhagriev <dzh...@gmail.com> wrote: > Hello, > > At the moment master branch contains the commented class FlumeSource. > Unfortunately, I can't find any information regarding the future support of > it. Can anyone, please, shed the light on it? > > Thanks, Alex. >
