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.
>

Reply via email to