flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ashish <paliwalash...@gmail.com>
Subject Re: Stopping the agent process if any sources/sinks fail during start
Date Thu, 12 Mar 2015 02:30:56 GMT
Can you please log a JIRA?

I am not aware of how to achieve this out of the box.

On Tue, Mar 10, 2015 at 1:04 AM, Michael Librodo <mike.librodo@gmail.com> wrote:
> Hi-
> I am currently investigating in a way for the flume agent to "fail fast" if
> any of the sources/sinks fail to start. It seems that there is no facility
> to do this based on the current architecture. Basically, I am working with
> the RMQ source plugin for flume. I would like the agent (jvm process) to
> halt if the RMQ source plugin fails to start (i.e. for some reason one of
> the preconditions for RMQ is not met). Right now, the only way I can think
> of doing this is Runtime.getRuntime().halt(1). It seems here
> https://github.com/apache/flume/blob/flume-1.5/flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleSupervisor.java#L249-263
> we catch every exception and just move on
> thanks in advance for the help
> --
> -mike.librodo


Blog: http://www.ashishpaliwal.com/blog
My Photo Galleries: http://www.pbase.com/ashishpaliwal

View raw message